#include <Broker.h>
Public Member Functions | |
Broker (const Options &configuration) | |
virtual uint16_t | getPort () const |
Return listening port. | |
virtual void | run () |
Run the broker. | |
virtual void | shutdown () |
Shut down the broker. | |
void | setStore (MessageStore *) |
MessageStore & | getStore () |
void | setAcl (AclModule *_acl) |
AclModule * | getAcl () |
QueueRegistry & | getQueues () |
ExchangeRegistry & | getExchanges () |
LinkRegistry & | getLinks () |
uint64_t | getStagingThreshold () |
DtxManager & | getDtxManager () |
DataDir & | getDataDir () |
Options & | getOptions () |
SessionManager & | getSessionManager () |
management::ManagementObject * | GetManagementObject (void) const |
management::Manageable * | GetVhostObject (void) const |
management::Manageable::status_t | ManagementMethod (uint32_t methodId, management::Args &args, std::string &text) |
void | registerProtocolFactory (const std::string &name, boost::shared_ptr< sys::ProtocolFactory >) |
Add to the broker's protocolFactorys. | |
void | accept () |
Accept connections. | |
void | connect (const std::string &host, uint16_t port, const std::string &transport, boost::function2< void, int, std::string > failed, sys::ConnectionCodec::Factory *=0) |
Create a connection to another broker. | |
void | connect (const Url &url, boost::function2< void, int, std::string > failed, sys::ConnectionCodec::Factory *=0) |
Create a connection to another broker. | |
uint32_t | queueMoveMessages (const std::string &srcQueue, const std::string &destQueue, uint32_t qty) |
Move messages from one queue to another. | |
boost::shared_ptr < sys::ProtocolFactory > | getProtocolFactory (const std::string &name=TCP_TRANSPORT) const |
boost::shared_ptr< sys::Poller > | getPoller () |
Expose poller so plugins can register their descriptors. | |
boost::shared_ptr < sys::ConnectionCodec::Factory > | getConnectionFactory () |
void | setConnectionFactory (boost::shared_ptr< sys::ConnectionCodec::Factory > f) |
Timer & | getTimer () |
Static Public Member Functions | |
static boost::intrusive_ptr < Broker > | create (const Options &configuration) |
static boost::intrusive_ptr < Broker > | create (int16_t port=DEFAULT_PORT) |
Public Attributes | |
boost::function< std::vector < Url >)> | getKnownBrokers |
Static Public Attributes | |
static const std::string | TCP_TRANSPORT |
Definition at line 77 of file Broker.h.
virtual uint16_t qpid::broker::Broker::getPort | ( | ) | const [virtual] |
Return listening port.
If called before bind this is the configured port. If called after it is the actual port, which will be different if the configured port is 0.
virtual void qpid::broker::Broker::run | ( | ) | [virtual] |
Run the broker.
Implements Runnable::run() so the broker can be run in a separate thread.
Implements qpid::sys::Runnable.
void qpid::broker::Broker::connect | ( | const std::string & | host, | |
uint16_t | port, | |||
const std::string & | transport, | |||
boost::function2< void, int, std::string > | failed, | |||
sys::ConnectionCodec::Factory * | = 0 | |||
) |
Create a connection to another broker.
void qpid::broker::Broker::connect | ( | const Url & | url, | |
boost::function2< void, int, std::string > | failed, | |||
sys::ConnectionCodec::Factory * | = 0 | |||
) |
Create a connection to another broker.
uint32_t qpid::broker::Broker::queueMoveMessages | ( | const std::string & | srcQueue, | |
const std::string & | destQueue, | |||
uint32_t | qty | |||
) |
Move messages from one queue to another.
A zero quantity means to move all messages
boost::shared_ptr<sys::Poller> qpid::broker::Broker::getPoller | ( | ) |
Expose poller so plugins can register their descriptors.