You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by tr...@apache.org on 2013/10/15 23:26:26 UTC

svn commit: r1532541 - in /qpid/trunk/qpid/extras/dispatch: src/agent.c tools/src/py/qdstat

Author: tross
Date: Tue Oct 15 21:26:26 2013
New Revision: 1532541

URL: http://svn.apache.org/r1532541
Log:
QPID-5238 - Changed the container agent's address to "$management" to match the specification.

Modified:
    qpid/trunk/qpid/extras/dispatch/src/agent.c
    qpid/trunk/qpid/extras/dispatch/tools/src/py/qdstat

Modified: qpid/trunk/qpid/extras/dispatch/src/agent.c
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/extras/dispatch/src/agent.c?rev=1532541&r1=1532540&r2=1532541&view=diff
==============================================================================
--- qpid/trunk/qpid/extras/dispatch/src/agent.c (original)
+++ qpid/trunk/qpid/extras/dispatch/src/agent.c Tue Oct 15 21:26:26 2013
@@ -262,7 +262,7 @@ dx_agent_t *dx_agent(dx_dispatch_t *dx)
     DEQ_INIT(agent->out_fifo);
     agent->lock    = sys_mutex();
     agent->timer   = dx_timer(dx, dx_agent_deferred_handler, agent);
-    agent->address = dx_router_register_address(dx, "agent", dx_agent_rx_handler, agent);
+    agent->address = dx_router_register_address(dx, "$management", dx_agent_rx_handler, agent);
 
     return agent;
 }

Modified: qpid/trunk/qpid/extras/dispatch/tools/src/py/qdstat
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/extras/dispatch/tools/src/py/qdstat?rev=1532541&r1=1532540&r2=1532541&view=diff
==============================================================================
--- qpid/trunk/qpid/extras/dispatch/tools/src/py/qdstat (original)
+++ qpid/trunk/qpid/extras/dispatch/tools/src/py/qdstat Tue Oct 15 21:26:26 2013
@@ -101,7 +101,7 @@ class BusManager:
         self.M = Messenger()
         self.M.start()
         self.M.route("amqp:/*", "amqp://%s/$1" % host)
-        self.address = "amqp:/_local/agent"
+        self.address = "amqp:/_local/$management"
         self.reply   = "amqp:/temp.reply-address/0001"    # FIX THIS!
         self.M.subscribe(self.reply)
 



---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org