@@ -116,7 +116,7 @@ package org.amqp.patterns.impl var queue:Declare = new Declare(); queue.queue = q; queue.autodelete = true; - sessionHandler.dispatch(new Command(queue)); + sessionHandler.rpc(new Command(queue), onQueueDeclareOk); } override protected function onQueueDeclareOk(event:ProtocolEvent):void { src/org/amqp/patterns/impl/RpcClientImpl.as 339f87ec3305d54c23256dd6a0d0d9b7d902e99f Gary Tsang gary@seriousbusiness.com http://github.com/0x6e6562/as3-amqp/commit/98b62612dbacd58706f3ff2a5cbed6e34c088329 98b62612dbacd58706f3ff2a5cbed6e34c088329 2009-10-09T10:24:48-07:00 2009-10-09T10:24:48-07:00 Adding onQueueDeclareOk Callback to Queue Declare command f9c97069cb2181ecb69733bca3f861d73b343d71 Gary Tsang gary@seriousbusiness.com