kea/1.4.0/kea-ik/hooks/amqp/src/amqppublisher.cc

#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;
}