28 #include <drizzled/replication_services.h>
29 #include <drizzled/plugin/transaction_applier.h>
31 #include "rabbitmq_handler.h"
50 const std::string _exchange;
51 const std::string _routingkey;
76 drizzled::plugin::ReplicationReturnCode
A TransactionApplier that sends the transactions to rabbitmq (or any AMQP 0-8 compliant message queue...
RabbitMQLog(const std::string &name, RabbitMQHandler *mqHandler)
Constructs a new RabbitMQLog.
wrapper around librabbitmq, hides error handling and reconnections etc TODO: add reconnection handlin...
drizzled::plugin::ReplicationReturnCode apply(drizzled::Session &session, const drizzled::message::Transaction &to_apply)
Serializes the transaction and uses a RabbiMQHandler to publish the message.