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
|