|
@@ -5,9 +5,8 @@
|
|
|
|
|
|
int AMQPPublisher::publish(std::string message)
|
|
|
{
|
|
|
+ AMQP amqp("amqp:5672");
|
|
|
try {
|
|
|
- AMQP amqp("amqp:5672");
|
|
|
-
|
|
|
AMQPExchange * ex = amqp.createExchange("kea");
|
|
|
|
|
|
ex->Declare("kea", "fanout");
|
|
@@ -27,5 +26,7 @@ int AMQPPublisher::publish(std::string message)
|
|
|
std::cout << e.getMessage() << std::endl;
|
|
|
}
|
|
|
|
|
|
+ amqp.closeChannel();
|
|
|
+
|
|
|
return 0;
|
|
|
}
|