21 #ifndef _QPID_CONSOLE_BROKER_H_
22 #define _QPID_CONSOLE_BROKER_H_
64 connThreadBody.bindExchange(
"qpid.management", key);
72 typedef std::map<uint64_t,Agent*> AgentMap;
73 static const int SYNC_TIME = 60;
79 std::string amqpSessionId;
98 std::stringstream queueName;
103 operational(false), shuttingDown(false), broker(_broker), subscriptions(0) {}
107 const std::string& exchange =
"qpid.management",
108 const std::string& routingKey =
"broker");
109 void bindExchange(
const std::string& exchange,
const std::string& key);
120 void updateAgent(
const Object&
object);
121 void incOutstanding();
122 void decOutstanding();
124 void appendAgents(std::vector<Agent*>& agents)
const;
126 friend std::ostream&
operator<<(std::ostream& o,
const Broker& k);
129 std::ostream&
operator<<(std::ostream& o,
const Broker& k);
Implement a subclass of MessageListener and subscribe it using the SubscriptionManager to receive mes...
AMQP 0-10 session API with keyword arguments.
A message sent to or received from the broker.
#define QPID_CONSOLE_EXTERN
std::ostream & operator<<(std::ostream &o, const Agent &agent)
Settings for a Connection.
A class to help create and manage subscriptions.
friend std::ostream & operator<<(std::ostream &o, const Broker &k)
QPID_CONSOLE_INLINE_EXTERN uint32_t getBrokerBank() const
Represents a connection to an AMQP broker.
A condition variable for thread synchronization.
std::string getUrl() const
QPID_CONSOLE_INLINE_EXTERN const framing::Uuid & getBrokerId() const
#define QPID_CONSOLE_INLINE_EXTERN
QPID_CONSOLE_INLINE_EXTERN const std::string & getSessionId() const
A UUID is represented as a boost::array of 16 bytes.
QPID_CONSOLE_INLINE_EXTERN void addBinding(const std::string &key)
Broker(SessionManager &sm, client::ConnectionSettings &settings)
This file was automatically generated from the AMQP specification.
Interface for objects that can be run, e.g.
friend class ConnectionThread
QPID_CONSOLE_INLINE_EXTERN const std::string & getError() const
QPID_CONSOLE_INLINE_EXTERN bool isConnected() const