From 171cc3e01add8d25d221f4a29d6961b8a1a9d32e Mon Sep 17 00:00:00 2001 From: Grant Limberg Date: Fri, 8 Mar 2019 10:20:19 -0800 Subject: reorder a couple of things --- controller/RabbitMQ.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'controller') diff --git a/controller/RabbitMQ.cpp b/controller/RabbitMQ.cpp index e6b8c819..096d3f53 100644 --- a/controller/RabbitMQ.cpp +++ b/controller/RabbitMQ.cpp @@ -48,13 +48,13 @@ void RabbitMQ::init() } static int chan = 0; - amqp_channel_open(_conn, ++chan); + _channel = ++chan; + amqp_channel_open(_conn, _channel); r = amqp_get_rpc_reply(_conn); if(r.reply_type != AMQP_RESPONSE_NORMAL) { throw std::runtime_error("Error opening communication channel"); } - _channel = chan; - + _q = amqp_queue_declare(_conn, _channel, amqp_cstring_bytes(_qName), 0, 0, 0, 0, amqp_empty_table); r = amqp_get_rpc_reply(_conn); if (r.reply_type != AMQP_RESPONSE_NORMAL) { -- cgit v1.2.3