1 #ifndef _QmfEngineResilientConnection_
2 #define _QmfEngineResilientConnection_
30 class ResilientConnectionImpl;
167 ResilientConnectionImpl* impl;
void setNotifyFd(int fd)
Establish a file descriptor for event notification.
void popEvent()
Discard the event on the front of the queue.
void destroySession(SessionHandle handle)
Destroy a created session.
Represents events that occur, unsolicited, from ResilientConnection.
bool createSession(const char *name, void *sessionContext, SessionHandle &handle)
Create a new AMQP session.
friend class ResilientConnectionImpl
bool getEvent(ResilientConnectionEvent &event)
Get the next event (if present) from the connection.
void declareQueue(SessionHandle handle, char *queue)
Declare an exclusive, auto-delete queue for a session.
void bind(SessionHandle handle, char *exchange, char *queue, char *key)
Bind a queue to an exchange.
ResilientConnection(const ConnectionSettings &settings)
Create a new resilient connection.
bool isConnected() const
Get the connected status of the resilient connection.
Settings for AMQP connections to the broker.
void unbind(SessionHandle handle, char *exchange, char *queue, char *key)
Remove a binding.
void notify()
Send a byte into the notify file descriptor.
void deleteQueue(SessionHandle handle, char *queue)
Delete a queue.
void sendMessage(SessionHandle handle, Message &message)
Send a message into the AMQP broker via a session.
ResilientConnection represents a Qpid connection that is resilient.