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 | f666063b070133646a75358988bc145a8b4a2c4f (patch) | |
| tree | ba888a2f0ce405ce13cbd090c86223e384e09dea | |
| parent | 4f541d5380ba69e105e1d40f0160e573c0b267aa (diff) | |
| download | qpid-python-f666063b070133646a75358988bc145a8b4a2c4f.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/qpid@955762 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | extras/qmf/src/py/qmf/console.py | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/extras/qmf/src/py/qmf/console.py b/extras/qmf/src/py/qmf/console.py index e7a89fb654..af7a895dc4 100644 --- a/extras/qmf/src/py/qmf/console.py +++ b/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 |