|
MoleQueue 0.9.0
|
#include <zeromqconnection.h>
Public Member Functions | |
| ZeroMqConnection (QObject *parentObject, zmq::context_t *context, zmq::socket_t *socket) | |
| ZeroMqConnection (QObject *parentObject, const QString &address) | |
| void | open () |
| void | start () |
| void | close () |
| bool | isOpen () |
| QString | connectionString () const |
| bool | send (const PacketType &packet, const EndpointIdType &endpoint) |
| void | flush () |
| Public Member Functions inherited from Connection | |
| Connection (QObject *parentObject=0) | |
Static Public Attributes | |
| static const QString | zeroMqPrefix |
Additional Inherited Members | |
| Signals inherited from Connection | |
| void | packetReceived (const MoleQueue::PacketType &packet, const MoleQueue::EndpointIdType &endpoint) |
| void | disconnected () |
Connection subclass using ZeroMQ.
|
virtual |
Open the connection
Implements Connection.
|
virtual |
Start receiving messages on this connection
Implements Connection.
|
virtual |
Close the connection. Once a conneciton is closed if can't reused.
Implements Connection.
|
virtual |
Implements Connection.
|
virtual |
Implements Connection.
|
virtual |
Send the packet on the connection to endpoint.
Implements Connection.
|
virtual |
Flush all pending messages to the other endpoint.
Implements Connection.