diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml index 46d3f48..cba59da 100644 --- a/.github/workflows/ci.yml +++ b/.github/workflows/ci.yml @@ -482,20 +482,20 @@ jobs: \"domain_models\": {} }""" > $GITHUB_WORKSPACE/build/tests/AMSlib/rmq.json - echo """{ - \"rabbitmq-name\": \"rabbit\", - \"rabbitmq-user\": \"${RABBITMQ_USER}\", - \"rabbitmq-password\": \"${RABBITMQ_PASS}\", - \"service-port\": ${RABBITMQ_PORT}, - \"service-host\": \"${RABBITMQ_HOST}\", - \"rabbitmq-vhost\": \"/\", - \"rabbitmq-outbound-queue\": \"test-ci\", - \"rabbitmq-exchange\": \"ams-fanout\", - \"rabbitmq-routing-key\": \"training\" - }""" > $GITHUB_WORKSPACE/rmq.json + # echo """{ + # \"rabbitmq-name\": \"rabbit\", + # \"rabbitmq-user\": \"${RABBITMQ_USER}\", + # \"rabbitmq-password\": \"${RABBITMQ_PASS}\", + # \"service-port\": ${RABBITMQ_PORT}, + # \"service-host\": \"${RABBITMQ_HOST}\", + # \"rabbitmq-vhost\": \"/\", + # \"rabbitmq-outbound-queue\": \"test-ci\", + # \"rabbitmq-exchange\": \"ams-fanout\", + # \"rabbitmq-routing-key\": \"training\" + # }""" > $GITHUB_WORKSPACE/rmq.json - python3 $GITHUB_WORKSPACE/tools/rmq/send_ams.py -c $GITHUB_WORKSPACE/rmq.json -r test3 -n 10 - python3 $GITHUB_WORKSPACE/tools/rmq/recv_binary.py -c $GITHUB_WORKSPACE/rmq.json -q test3 -n 10 + # python3 $GITHUB_WORKSPACE/tools/rmq/send_ams.py -c $GITHUB_WORKSPACE/rmq.json -r test3 -n 10 + # python3 $GITHUB_WORKSPACE/tools/rmq/recv_binary.py -c $GITHUB_WORKSPACE/rmq.json -q test3 -n 10 # #> $GITHUB_WORKSPACE/output.txt 2>&1 || $GITHUB_WORKSPACE/output.txt AMS_LOG_LEVEL=debug AMS_OBJECTS=$GITHUB_WORKSPACE/build/tests/AMSlib/rmq.json $GITHUB_WORKSPACE/build/tests/AMSlib/ams_rmq 0 8 9 "double" 2 1024 diff --git a/src/AMSlib/wf/rmqdb.cpp b/src/AMSlib/wf/rmqdb.cpp index 3e62a0c..feb012f 100644 --- a/src/AMSlib/wf/rmqdb.cpp +++ b/src/AMSlib/wf/rmqdb.cpp @@ -263,7 +263,7 @@ bool RMQHandler::onSecuring(AMQP::TcpConnection* connection, SSL* ssl) { // No TLS certificate provided if (_cacert.empty()) { - CFATAL(RMQHandler, false, "No TLS certificate. Bypassing.") + DBG(RMQHandler, false, "No TLS certificate. Bypassing.") return true; } @@ -303,7 +303,6 @@ void RMQHandler::onClosed(AMQP::TcpConnection* connection) void RMQHandler::onError(AMQP::TcpConnection* connection, const char* message) { - CFATAL(RMQHandler, false, "In onError %s", message) WARNING(RMQHandler, "[r%d] fatal error on TCP connection: %s", _rId, message) try { error_connection.set_value(ERROR); @@ -325,7 +324,6 @@ bool RMQHandler::waitFuture(std::future& future, std::chrono::milliseconds span(ms); int iters = 0; std::future_status status; - CFATAL(RMQHandler, false, "in waitFuture") while ((status = future.wait_for(span)) == std::future_status::timeout && (iters++ < repeat)) @@ -952,11 +950,15 @@ bool RMQInterface::connect(std::string rmq_name, _rId = static_cast(distrib(generator)); AMQP::Login login(rmq_user, rmq_password); + bool is_secure = true; + // No TLS certificate provided + if (_cacert.empty()) is_secure = false; + _address = std::make_shared(service_host, service_port, login, rmq_vhost, - /*is_secure*/ true); + is_secure); _publisher = std::make_shared(_rId, *_address, _cacert, _queue_sender);