28 #include <drizzled/replication_services.h>
29 #include <drizzled/plugin/transaction_applier.h>
33 namespace drizzle_plugin {
48 pthread_mutex_t publishLock;
49 std::string sysvar_endpoint;
62 ZeroMQLog(
const std::string &name,
const std::string &endpoint);
94 drizzled::plugin::ReplicationReturnCode
bool setEndpoint(std::string new_endpoint)
Setter for endpoint.
A TransactionApplier that publishes transaction on a zeromq pub socket.
std::string & getEndpoint()
Getter for endpoint.
ZeroMQLog(const std::string &name, const std::string &endpoint)
Constructs a new ZeroMQLog.
drizzled::plugin::ReplicationReturnCode apply(drizzled::Session &session, const drizzled::message::Transaction &to_apply)
Serializes the transaction and publishes the message to zmq.