diff --git a/services/tunnelbroker/src/Amqp/AmqpManager.cpp b/services/tunnelbroker/src/Amqp/AmqpManager.cpp --- a/services/tunnelbroker/src/Amqp/AmqpManager.cpp +++ b/services/tunnelbroker/src/Amqp/AmqpManager.cpp @@ -37,8 +37,8 @@ }); AMQP::Table arguments; - arguments["x-message-ttl"] = AMQP_MESSAGE_TTL; - arguments["x-expires"] = AMQP_QUEUE_TTL; + arguments["x-message-ttl"] = std::to_string(AMQP_MESSAGE_TTL); + arguments["x-expires"] = std::to_string(AMQP_QUEUE_TTL); this->amqpChannel->declareExchange(fanoutExchangeName, AMQP::fanout); this->amqpChannel->declareQueue(tunnelbrokerID, AMQP::durable, arguments) .onSuccess([this, tunnelbrokerID, fanoutExchangeName](