We are using JBossMQ in catalog management project and during our load tests we have
observed the following behaviour.
On a shutdown of JBoss with JBossMQ a queue message is delivered more than ONCE.
For reproduction we use the following szenario:
One JBoss, no cluster
One sender, many listeners are attached to the queue
JBoss 3.2.6 downloaded zip unpack... and start (with default configuration)
If I send a message and one listener executes the onMessage method while I start the
JBoss shutdown then
ALL listeners receive this message with a new message redelivered count.
Is that a programmers fault or a bug ?
thanks for reply
Wolf
The JBoss logging message was:
| 14:54:31,089 WARN [org.jboss.mq.server.BasicQueue] Error during stop - removing
subscriber Subscription[subId=-2147483648connection=Connect
| ionToken:ID:5/0cc260fa86d1fa11b7396a035c117fa7 destination=QUEUE.testQueue
messageSelector=null Local Create]
| javax.jms.InvalidDestinationException: The subscription was registered with a
destination that does not exist !
| at
org.jboss.mq.server.ClientConsumer.removeSubscription(ClientConsumer.java:246)
| at org.jboss.mq.server.BasicQueue.stop(BasicQueue.java:640)
| at org.jboss.mq.server.JMSQueue.close(JMSQueue.java:152)
| at
org.jboss.mq.server.JMSDestinationManager.closeDestination(JMSDestinationManager.java:806)
| at
org.jboss.mq.server.jmx.DestinationMBeanSupport.stopService(DestinationMBeanSupport.java:138)
| at
org.jboss.system.ServiceMBeanSupport.jbossInternalStop(ServiceMBeanSupport.java:319)
| at
org.jboss.system.ServiceMBeanSupport.jbossInternalLifecycle(ServiceMBeanSupport.java:223)
| at sun.reflect.GeneratedMethodAccessor14.invoke(Unknown Source)
| at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
| at java.lang.reflect.Method.invoke(Method.java:324)
| at
org.jboss.mx.server.ReflectedDispatcher.dispatch(ReflectedDispatcher.java:60)
| at org.jboss.mx.server.Invocation.dispatch(Invocation.java:61)
| at org.jboss.mx.server.Invocation.dispatch(Invocation.java:53)
| at org.jboss.mx.server.Invocation.invoke(Invocation.java:86)
| at
org.jboss.mx.server.AbstractMBeanInvoker.invoke(AbstractMBeanInvoker.java:185)
| at org.jboss.mx.server.MBeanServerImpl.invoke(MBeanServerImpl.java:473)
| at
org.jboss.system.ServiceController$ServiceProxy.invoke(ServiceController.java:837)
| at $Proxy18.stop(Unknown Source)
| at org.jboss.system.ServiceController.stop(ServiceController.java:449)
| at org.jboss.system.ServiceController.stop(ServiceController.java:440)
| at org.jboss.system.ServiceController.stop(ServiceController.java:440)
| at org.jboss.system.ServiceController.stop(ServiceController.java:440)
| at org.jboss.system.ServiceController.stop(ServiceController.java:440)
| at sun.reflect.GeneratedMethodAccessor78.invoke(Unknown Source)
| at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
| at java.lang.reflect.Method.invoke(Method.java:324)
| at
org.jboss.mx.server.ReflectedDispatcher.dispatch(ReflectedDispatcher.java:60)
| at org.jboss.mx.server.Invocation.dispatch(Invocation.java:61)
| at org.jboss.mx.server.Invocation.dispatch(Invocation.java:53)
| at org.jboss.mx.server.Invocation.invoke(Invocation.java:86)
| at
org.jboss.mx.server.AbstractMBeanInvoker.invoke(AbstractMBeanInvoker.java:185)
| at org.jboss.mx.server.MBeanServerImpl.invoke(MBeanServerImpl.java:473)
| at org.jboss.mx.util.MBeanProxyExt.invoke(MBeanProxyExt.java:176)
| at $Proxy4.stop(Unknown Source)
| at org.jboss.deployment.SARDeployer.stop(SARDeployer.java:285)
| at org.jboss.deployment.MainDeployer.stop(MainDeployer.java:492)
| at org.jboss.deployment.MainDeployer.undeploy(MainDeployer.java:475)
| at org.jboss.deployment.MainDeployer.shutdown(MainDeployer.java:362)
| at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
| at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
| at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
| at java.lang.reflect.Method.invoke(Method.java:324)
| at
org.jboss.mx.server.ReflectedDispatcher.dispatch(ReflectedDispatcher.java:60)
| at org.jboss.mx.server.Invocation.dispatch(Invocation.java:61)
| at org.jboss.mx.server.Invocation.dispatch(Invocation.java:53)
| at org.jboss.mx.server.Invocation.invoke(Invocation.java:86)
| at
org.jboss.mx.server.AbstractMBeanInvoker.invoke(AbstractMBeanInvoker.java:185)
| at org.jboss.mx.server.MBeanServerImpl.invoke(MBeanServerImpl.java:473)
| at
org.jboss.system.server.ServerImpl$ShutdownHook.shutdownDeployments(ServerImpl.java:884)
| at
org.jboss.system.server.ServerImpl$ShutdownHook.shutdown(ServerImpl.java:859)
| at org.jboss.system.server.ServerImpl$ShutdownHook.run(ServerImpl.java:846)
|
Sender will send with a not transacted Session and AUTO_ACKNOWLEDGE
Listener:
| .... start Listener() {
| QueueConnectionFactory qcf =
(QueueConnectionFactory)iniCtx.lookup("UIL2ConnectionFactory");
| QueueConnection conn = qcf.createQueueConnection();
| Queue que = (Queue) iniCtx.lookup("queue/testQueue");
| QueueSession session =
conn.createQueueSession(false,QueueSession.AUTO_ACKNOWLEDGE);
|
|
| QueueReceiver recv = session.createReceiver(que);
| recv.setMessageListener(new QueueListener());
| conn.start();
| ......}
|
| public class QueueListener implements MessageListener {
| public void onMessage(Message msg) {
| TextMessage m = (TextMessage)msg;
| try {
| System.out.println("onMessage() : "+new
java.text.SimpleDateFormat("yyyyMMdd HHmmssSSS").format(new Date())+"\n"+msg);
| try {
| System.out.println("WAIT");
| Thread.sleep(10000);
| System.out.println("WAIT END");
| }catch(InterruptedException e) {}
| }catch(Throwable t) {
| t.printStackTrace();
| }
| System.out.println("ENDE onMessage()");
| }
| }
|
|
View the original post :
http://www.jboss.org/index.html?module=bb&op=viewtopic&p=3852763#3852763
Reply to the post :
http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=3852763
-------------------------------------------------------
This SF.net email is sponsored by: IT Product Guide on ITManagersJournal
Use IT products in your business? Tell us what you think of them. Give us
Your Opinions, Get Free ThinkGeek Gift Certificates! Click to find out more
http://productguide.itmanagersjournal.com/guidepromo.tmpl
_______________________________________________
JBoss-user mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-user
