diff options
| author | Kenneth Anthony Giusti <kgiusti@apache.org> | 2010-06-17 22:04:24 +0000 |
|---|---|---|
| committer | Kenneth Anthony Giusti <kgiusti@apache.org> | 2010-06-17 22:04:24 +0000 |
| commit | 60ddf89027817f0f7860c7d9f86af161ac540bc8 (patch) | |
| tree | 1b55eea1feaaa083f63240498673b24c45d82dc7 | |
| parent | df8ed89d564f506eb1515bd61199d6dd493d1066 (diff) | |
| download | qpid-python-60ddf89027817f0f7860c7d9f86af161ac540bc8.tar.gz | |
QPID-2677: send agent locate req after binding to agent.ind.data
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@955762 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/extras/qmf/src/py/qmf/console.py | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/qpid/extras/qmf/src/py/qmf/console.py b/qpid/extras/qmf/src/py/qmf/console.py index e7a89fb654..af7a895dc4 100644 --- a/qpid/extras/qmf/src/py/qmf/console.py +++ b/qpid/extras/qmf/src/py/qmf/console.py @@ -2147,8 +2147,6 @@ class Broker(Thread): self._setHeader(codec, 'B') msg = self._message(codec.encoded) self._send(msg) - if self.brokerSupportsV2: - self._v2SendAgentLocate() return True # connection complete @@ -2341,6 +2339,11 @@ class Broker(Thread): self.amqpSession.exchange_bind(exchange="qmf.default.topic", queue=self.v2_topic_queue_lo, binding_key=key) + # solicit an agent locate now, after we bind to agent.ind.data, + # because the agent locate will cause the agent to publish a + # data indication - and now we're able to receive it! + self._v2SendAgentLocate() + if self.reqsOutstanding == 0 and self.syncInFlight: self.syncInFlight = False |