From 814104356085198fb6aa09f6f5e6f39406d2fc06 Mon Sep 17 00:00:00 2001 From: Grant Limberg Date: Wed, 6 Mar 2019 16:16:49 -0800 Subject: finish up rabbitmq integration --- controller/RabbitMQ.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'controller/RabbitMQ.cpp') diff --git a/controller/RabbitMQ.cpp b/controller/RabbitMQ.cpp index 34efcde4..e6b8c819 100644 --- a/controller/RabbitMQ.cpp +++ b/controller/RabbitMQ.cpp @@ -58,13 +58,13 @@ void RabbitMQ::init() _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) { - throw std::runtime_error("Error declaring queue"); + throw std::runtime_error("Error declaring queue " + std::string(_qName)); } amqp_basic_consume(_conn, _channel, amqp_cstring_bytes(_qName), amqp_empty_bytes, 0, 1, 0, amqp_empty_table); r = amqp_get_rpc_reply(_conn); if (r.reply_type != AMQP_RESPONSE_NORMAL) { - throw std::runtime_error("Error conuming"); + throw std::runtime_error("Error consuming queue " + std::string(_qName)); } fprintf(stderr, "RabbitMQ Init OK %s\n", _qName); } -- cgit v1.2.3