qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Rajith Attapattu <rajit...@gmail.com>
Subject Re: IllegalStateException after failed over
Date Wed, 11 Mar 2009 18:24:44 GMT
Hello Stephan,

Looking at the code I see that if a message was acked after failover
it does throw the IllegalStateException
I am not convinced if this should be the correct behaviour.
I will raise this issue on the dev list and see why this was done this way.

Regards,

Rajith

On Wed, Mar 11, 2009 at 2:48 AM, Stephen Lau <stephen.lau@xml-asia.org> wrote:
> Hi all,
>
> I am testing fail over test with C++ broker and Java client, using Java perftests examples.
> In Java client, I tried to acknowledge message after failed over, as it was using client
acknowledge mode.
> It threw an exception:
>
> Dispatcher-Channel-1 2009-03-11 14:27:27,709 WARN [apache.qpid.topic.Listener] There
was a JMSException during onMessage.
> javax.jms.IllegalStateException: has failed over
>  at org.apache.qpid.client.AMQSession.acknowledge(AMQSession.java:530)
>  at org.apache.qpid.client.message.AMQMessageDelegate_0_10.acknowledge(AMQMessageDelegate_0_10.java:842)
>  at org.apache.qpid.client.message.AbstractJMSMessage.acknowledge(AbstractJMSMessage.java:345)
>  at org.apache.qpid.topic.Listener.onMessage(Listener.java:201)
>  at org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessageConsumer.java:730)
>  at org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicMessageConsumer_0_10.java:156)
>  at org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessageConsumer.java:696)
>  at org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicMessageConsumer_0_10.java:178)
>  at org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicMessageConsumer_0_10.java:1)
>  at org.apache.qpid.client.AMQSession$Dispatcher.notifyConsumer(AMQSession.java:2937)
>  at org.apache.qpid.client.AMQSession$Dispatcher.dispatchMessage(AMQSession.java:2881)
>  at org.apache.qpid.client.AMQSession$Dispatcher.access$0(AMQSession.java:2853)
>  at org.apache.qpid.client.AMQSession.dispatch(AMQSession.java:2686)
>  at org.apache.qpid.client.message.UnprocessedMessage.dispatch(UnprocessedMessage.java:55)
>  at org.apache.qpid.client.AMQSession$Dispatcher.run(AMQSession.java:2814)
>  at java.lang.Thread.run(Thread.java:619)
>
> Any idea?
>
> Regards,
> Stephen



-- 
Regards,

Rajith Attapattu
Red Hat
http://rajith.2rlabs.com/

---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org


Mime
View raw message