|
@@ -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) {
|