123456789101112131415161718192021222324252627 |
- #include <unistd.h>
- #include <string>
- #include "common.h"
- #include "amqppublisher.h"
- #include <SimpleAmqpClient/SimpleAmqpClient.h>
- int AMQPPublisher::publish(std::string message)
- {
- using namespace AmqpClient;
- Channel::ptr_t channel = Channel::Create(host, 5672, user, password, "/");
- BasicMessage::ptr_t basic_message = BasicMessage::Create(message);
- basic_message->Expiration("10000");
- basic_message->DeliveryMode(BasicMessage::dm_persistent);
- basic_message->ContentType("text/text");
- basic_message->ContentEncoding("UTF-8");
- channel->DeclareExchange("kea", "fanout");
- std::string queue = channel->DeclareQueue("kea", false, false, false, false);
- channel->BindQueue(queue, "kea");
- channel->BasicPublish("kea", queue, basic_message, false, false);
- return 0;
- }
|