qpid::broker::Broker Class Reference

A broker instance. More...

#include <Broker.h>

Inheritance diagram for qpid::broker::Broker:

[legend]

Collaboration diagram for qpid::broker::Broker:

[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 *)
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

---

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:

• /home/nsantos/projects/mrg-team/testing/magnum/f10/qpidc/qpid/cpp/src/qpid/broker/Broker.h