qpid::broker::Broker Class Reference

A broker instance. More...

#include <Broker.h>

Inheritance diagram for qpid::broker::Broker:

Inheritance graph
[legend]
Collaboration diagram for qpid::broker::Broker:

Collaboration graph
[legend]

List of all members.

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 *)
MessageStoregetStore ()
void setAcl (AclModule *_acl)
AclModule * getAcl ()
QueueRegistrygetQueues ()
ExchangeRegistry & getExchanges ()
LinkRegistry & getLinks ()
uint64_t getStagingThreshold ()
DtxManager & getDtxManager ()
DataDirgetDataDir ()
Options & getOptions ()
SessionManagergetSessionManager ()
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


Detailed Description

A broker instance.

Definition at line 77 of file Broker.h.


Member Function Documentation

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.


The documentation for this class was generated from the following file:

Generated on Thu Oct 16 13:38:09 2008 for Qpid by  doxygen 1.5.6