I test again exclusive queue through JNDI. My first listener create an
exclusive queue. My second listener is blocked and wait that my first listner
unlock my queue. I would prefer to get an exception in this case and not an
simple debug message like this :
IoReceiver - /127.0.0.1:26969 2009-03-24 10:38:08,859 DEBUG
[apache.qpid.transport.Connection] RECV: [conn:1c86be5] ch=0
ExecutionException(errorCode=RESOURCE_LOCKED, commandId=2, classCode=8,
commandCode=1, fieldIndex=0, description=resource-locked: Cannot grant
exclusive access to queue TEST (qpid/broker/SessionAdapter.cpp:388),
errorInfo={})
is this possible ?
The problem is that after I get this exception because of timeout :
IoReceiver - /127.0.0.1:26969 2009-03-24 10:40:08,597 DEBUG
[apache.qpid.transport.Connection] RECV: [conn:1c86be5] ch=0
ConnectionHeartbeat()
Exception in thread "main" org.apache.qpid.transport.SessionException: timed
out waiting for sync: complete = 1, point = 3
at org.apache.qpid.transport.Session.sync(Session.java:684)
at org.apache.qpid.transport.Session.sync(Session.java:653)
at
org.apache.qpid.client.AMQSession_0_10.sendClose(AMQSession_0_10.java:324)
at org.apache.qpid.client.AMQSession.close(AMQSession.java:647)
at org.apache.qpid.client.AMQSession.close(AMQSession.java:488)
at
com.axway.test.queuer.QueueListener.JMSQListener.main(JMSQListener.java:168)
And unfortunately it could be confusing and bad interpreted...
Do I need to raise a JIRA ?
See my comment on QPID-1758. It's not meaningful to create an exclusive
queue with qpid-config because that queue will be exclusive to the
session created by qpid-config.
My understanding is that a queue is declared 'exclusive' by the client
that wants to use it. Once the session closes, the queue is available
for other sessions but the exclusive attribute no longer holds unless
it's re-declared.
-Ted
ffrenchm wrote:
> Hello again,
>
> is there anybody who can explains me where I'm wrong on my tests or if there
> is any bug about it ?
>
> Thanks
>
>
>
> ffrenchm wrote:
>
>> Hello,
>>
>> I'm going to make some tests with exclusive queue.
>>
>> I declare them exclusive thanks a patched qpid-console published
>> https://issues.apache.org/jira/browse/QPID-1758 here .
>>
>> test 1 :
>> ----------
>>
>> after restart I loose my exclusive option on my queue and there is a
>> strange behavior
>> when I try to redefine my queue...
>>
>> $./qpid-config -a localhost:5671 add queue TEST --exclusive --durable
>> $./qpid-config -a localhost:5671 queues
>> Queue Name Attributes
>> ==================================================
>> TEST --durable excl --file-size=24 --file-count=8
>> reply-dekatonshir.18810.1 auto-del excl
>> topic-dekatonshir.18810.1 auto-del excl
>>
>> (restart qpidd)
>>
>> $./qpid-config -a localhost:5671 queues
>> Queue Name Attributes
>> ==================================================
>> TEST --durable --file-size=24 --file-count=8
>> reply-dekatonshir.18838.1 auto-del excl
>> topic-dekatonshir.18838.1 auto-del excl
>> $./qpid-config -a localhost:5671 del queue TEST --force
>> $./qpid-config -a localhost:5671 add queue TEST --exclusive --durable
>> $./qpid-config -a localhost:5671 queues
>> Queue Name Attributes
>> ==================================================
>> TEST --durable --file-size=24 --file-count=8
>> TEST --durable excl --file-size=24 --file-count=8
>> reply-dekatonshir.18919.1 auto-del excl
>> topic-dekatonshir.18919.1 auto-del excl
>>
>> (restart qpidd)
>>
>> $./qpid-config -a localhost:5671 queues
>> Queue Name Attributes
>> ==================================================
>> TEST --durable --file-size=24 --file-count=8
>> reply-dekatonshir.18967.1 auto-del excl
>> topic-dekatonshir.18967.1 auto-del excl
>>
>> test 2 :
>> -----------
>>
>> I define an exclusive queue TEST and then I start 2 JMS consumers on this
>> queue. When starting the
>> second consumer I do not have any options telling me that there is already
>> a consumer on my exclusive
>> queue. I start a JMS publisher which send a lot of messages : the two
>> consumers are receiving messages...
>>
>> Do I make some mistakes here ? I do no understand where ....
>>
>>
>> Thanks for all
>>
>>
>>
>
>
--
View this message in context:
http://n2.nabble.com/tests-on-exclusive-queue-tp2498394p2525604.html
Sent from the Apache Qpid users mailing list archive at Nabble.com.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
