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.
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,
Rob
