You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by kg...@apache.org on 2010/06/18 00:04:25 UTC
svn commit: r955762 - /qpid/trunk/qpid/extras/qmf/src/py/qmf/console.py
Author: kgiusti
Date: Thu Jun 17 22:04:24 2010
New Revision: 955762
URL: http://svn.apache.org/viewvc?rev=955762&view=rev
Log:
QPID-2677: send agent locate req after binding to agent.ind.data
Modified:
qpid/trunk/qpid/extras/qmf/src/py/qmf/console.py
Modified: qpid/trunk/qpid/extras/qmf/src/py/qmf/console.py
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/extras/qmf/src/py/qmf/console.py?rev=955762&r1=955761&r2=955762&view=diff
==============================================================================
--- qpid/trunk/qpid/extras/qmf/src/py/qmf/console.py (original)
+++ qpid/trunk/qpid/extras/qmf/src/py/qmf/console.py Thu Jun 17 22:04:24 2010
@@ -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
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org