summaryrefslogtreecommitdiff
path: root/qpid/cpp/include
diff options
context:
space:
mode:
authorTed Ross <tross@apache.org>2010-06-03 20:23:30 +0000
committerTed Ross <tross@apache.org>2010-06-03 20:23:30 +0000
commit095fb80c67258ab00a2654bdd4a094f4d37ed4b8 (patch)
tree3644e74d8df8f20de5f0a02b45db310e04a66777 /qpid/cpp/include
parent0fce2485ea635c86bdf86b41ea9187ea50fe767d (diff)
downloadqpid-python-095fb80c67258ab00a2654bdd4a094f4d37ed4b8.tar.gz
QPID-2644 - Console examples sometimes fail due to not waiting for the broker connection to complete
Moved 'Broker::waitForStable' from private to public, used this function in the examples to hold off until the broker is fully connected. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@951141 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/include')
-rw-r--r--qpid/cpp/include/qpid/console/Broker.h14
1 files changed, 7 insertions, 7 deletions
diff --git a/qpid/cpp/include/qpid/console/Broker.h b/qpid/cpp/include/qpid/console/Broker.h
index af163b8bfd..0b2d1bcb61 100644
--- a/qpid/cpp/include/qpid/console/Broker.h
+++ b/qpid/cpp/include/qpid/console/Broker.h
@@ -55,15 +55,16 @@ namespace console {
client::ConnectionSettings& settings);
QPID_CONSOLE_EXTERN ~Broker();
- bool isConnected() const { return connected; }
- const std::string& getError() const { return error; }
- const std::string& getSessionId() const { return amqpSessionId; }
- const framing::Uuid& getBrokerId() const { return brokerId; }
- uint32_t getBrokerBank() const { return 1; }
- void addBinding(const std::string& key) {
+ QPID_CONSOLE_EXTERN bool isConnected() const { return connected; }
+ QPID_CONSOLE_EXTERN const std::string& getError() const { return error; }
+ QPID_CONSOLE_EXTERN const std::string& getSessionId() const { return amqpSessionId; }
+ QPID_CONSOLE_EXTERN const framing::Uuid& getBrokerId() const { return brokerId; }
+ QPID_CONSOLE_EXTERN uint32_t getBrokerBank() const { return 1; }
+ QPID_CONSOLE_EXTERN void addBinding(const std::string& key) {
connThreadBody.bindExchange("qpid.management", key);
}
QPID_CONSOLE_EXTERN std::string getUrl() const;
+ QPID_CONSOLE_EXTERN void waitForStable();
private:
friend class SessionManager;
@@ -117,7 +118,6 @@ namespace console {
void received(client::Message& msg);
void resetAgents();
void updateAgent(const Object& object);
- void waitForStable();
void incOutstanding();
void decOutstanding();
void setBrokerId(const framing::Uuid& id) { brokerId = id; }