30 #include <amqp_framing.h>
31 #include <netinet/in.h>
33 namespace drizzle_plugin
47 virtual const char* what()
const throw()
61 amqp_connection_state_t rabbitmqConnection;
63 const std::string &hostname;
66 const std::string &username;
67 const std::string &password;
68 const std::string &virtualhost;
69 const std::string &exchange;
70 const std::string &routingKey;
71 pthread_mutex_t publishLock;
91 const std::string &username,
92 const std::string &password,
93 const std::string &virtualhost,
94 const std::string &exchange,
95 const std::string &routingKey)
116 void disconnect() throw(rabbitmq_handler_exception);
131 void handleAMQPError(amqp_rpc_reply_t x, std::
string context) throw(rabbitmq_handler_exception);
133 void connect() throw(rabbitmq_handler_exception);