On Mon, Jan 18, 2010 at 6:10 PM, Robert Godfrey <[email protected]> wrote: > Hi Rajith, > > 2010/1/18 Rajith Attapattu <[email protected]> > >> Rob, >> >> I noticed the following in AMQSession_0_8.java >> >> + public void sync() throws AMQException >> + { >> + declareExchange(new AMQShortString("amq.direct"), new >> AMQShortString("direct"), false); >> + } >> >> It's quite possible that I misunderstood the intent here, but it kinda >> looked odd to me. >> So I thought I'd ask just to be sure. >> >> Rajith >> >> > the intent is to add a way of introducing a sync operation - unfortunately > 0-8 has no sync command so the closes we can get it to passively declare > amq.direct - an operation that should always complete successfully on a > compliant broker - and wait for the -ok to come back. Yes it makes sense now !
> Obviously it's a bit of a hack - and the only real use case is in the unit > tests so far... > > Hope this clarifies things, Yes it does. Thank you sir. > > Rob > -- Regards, Rajith Attapattu Red Hat http://rajith.2rlabs.com/ --------------------------------------------------------------------- Apache Qpid - AMQP Messaging Implementation Project: http://qpid.apache.org Use/Interact: mailto:[email protected]
