3 Replies Latest reply on Apr 9, 2008 11:39 AM by Adrian Brock

    Problem shutting down persistant JMS queue.

    Alexander Derenbach Newbie

      Hi together,

      I have a problem with a persitant JMS queue (JBoss 4.2.2 with JBoss MQ).
      It seems that the queue is not waiting for the MDBs to return the onMessage() method to commit or rollback the transaction. After shutting down and restart of the queue, many messages are duplicated.

      Is this a known bug or is something with my configuration not right.

      Thanks and greets, Alex

      A simple testcase which sends just incrementing Longs as messages and a MDB which just logs them out has this log:

      WorkManager(2)-111 1777034 INFO 20080407 16:43:16,082 upload.TestQueueMDB [15] Got: 806
      WorkManager(2)-122 1777081 INFO 20080407 16:43:16,129 upload.TestQueueMDB [15] Got: 807
      WorkManager(2)-117 1777097 INFO 20080407 16:43:16,145 upload.TestQueueMDB [15] Got: 808
      WorkManager(2)-115 1777144 INFO 20080407 16:43:16,192 upload.TestQueueMDB [15] Got: 809
      WorkManager(2)-121 1777315 INFO 20080407 16:43:16,363 upload.TestQueueMDB [15] Got: 810
      WorkManager(2)-125 1777331 INFO 20080407 16:43:16,379 upload.TestQueueMDB [15] Got: 811
      WorkManager(2)-127 1777409 INFO 20080407 16:43:16,457 upload.TestQueueMDB [15] Got: 812
      WorkManager(2)-120 1777425 INFO 20080407 16:43:16,473 upload.TestQueueMDB [15] Got: 813
      WorkManager(2)-123 1777456 INFO 20080407 16:43:16,504 upload.TestQueueMDB [15] Got: 815
      WorkManager(2)-109 1777456 INFO 20080407 16:43:16,504 upload.TestQueueMDB [15] Got: 814
      WorkManager(2)-134 1777456 INFO 20080407 16:43:16,504 upload.TestQueueMDB [15] Got: 816
      WorkManager(2)-128 1777472 INFO 20080407 16:43:16,520 upload.TestQueueMDB [15] Got: 817
      ScannerThread 1777472 INFO 20080407 16:43:16,520 upload.TestQueueMDB [] destroying worker 13
      ScannerThread 1777472 INFO 20080407 16:43:16,520 upload.TestQueueMDB [] destroying worker 4
      ScannerThread 1777472 INFO 20080407 16:43:16,520 upload.TestQueueMDB [] destroying worker 3
      ScannerThread 1777472 INFO 20080407 16:43:16,520 upload.TestQueueMDB [] destroying worker 15
      ScannerThread 1777472 INFO 20080407 16:43:16,520 upload.TestQueueMDB [] destroying worker 10
      ScannerThread 1777472 INFO 20080407 16:43:16,520 upload.TestQueueMDB [] destroying worker 14
      ScannerThread 1777472 INFO 20080407 16:43:16,520 upload.TestQueueMDB [] destroying worker 7
      ScannerThread 1777472 INFO 20080407 16:43:16,520 upload.TestQueueMDB [] destroying worker 6
      ScannerThread 1777472 INFO 20080407 16:43:16,520 upload.TestQueueMDB [] destroying worker 12
      ScannerThread 1777472 INFO 20080407 16:43:16,520 upload.TestQueueMDB [] destroying worker 1
      ScannerThread 1777472 INFO 20080407 16:43:16,520 upload.TestQueueMDB [] destroying worker 11
      ScannerThread 1777472 INFO 20080407 16:43:16,520 upload.TestQueueMDB [] destroying worker 5
      ScannerThread 1777472 INFO 20080407 16:43:16,520 upload.TestQueueMDB [] destroying worker 8
      ScannerThread 1777472 INFO 20080407 16:43:16,520 upload.TestQueueMDB [] destroying worker 9
      ScannerThread 1777472 INFO 20080407 16:43:16,520 upload.TestQueueMDB [] destroying worker 2
      WorkManager(2)-133 1810050 INFO 20080407 16:43:49,098 upload.TestQueueMDB [] Creating worker 1
      WorkManager(2)-126 1810050 INFO 20080407 16:43:49,098 upload.TestQueueMDB [] Creating worker 2
      WorkManager(2)-140 1810050 INFO 20080407 16:43:49,098 upload.TestQueueMDB [] Creating worker 3
      WorkManager(2)-135 1810050 INFO 20080407 16:43:49,098 upload.TestQueueMDB [] Creating worker 4
      WorkManager(2)-130 1810050 INFO 20080407 16:43:49,098 upload.TestQueueMDB [] Creating worker 5
      WorkManager(2)-144 1810050 INFO 20080407 16:43:49,098 upload.TestQueueMDB [] Creating worker 6
      WorkManager(2)-142 1810050 INFO 20080407 16:43:49,098 upload.TestQueueMDB [] Creating worker 7
      WorkManager(2)-148 1810050 INFO 20080407 16:43:49,098 upload.TestQueueMDB [] Creating worker 8
      WorkManager(2)-132 1810050 INFO 20080407 16:43:49,098 upload.TestQueueMDB [] Creating worker 9
      WorkManager(2)-131 1810050 INFO 20080407 16:43:49,098 upload.TestQueueMDB [] Creating worker 10
      WorkManager(2)-139 1810066 INFO 20080407 16:43:49,114 upload.TestQueueMDB [] Creating worker 11
      WorkManager(2)-141 1810066 INFO 20080407 16:43:49,114 upload.TestQueueMDB [] Creating worker 12
      WorkManager(2)-145 1810066 INFO 20080407 16:43:49,114 upload.TestQueueMDB [] Creating worker 13
      WorkManager(2)-153 1810066 INFO 20080407 16:43:49,114 upload.TestQueueMDB [] Creating worker 14
      WorkManager(2)-149 1810066 INFO 20080407 16:43:49,114 upload.TestQueueMDB [] Creating worker 15
      WorkManager(2)-133 1810566 INFO 20080407 16:43:49,614 upload.TestQueueMDB [1] Got: 618
      WorkManager(2)-130 1810566 INFO 20080407 16:43:49,614 upload.TestQueueMDB [5] Got: 623
      WorkManager(2)-126 1810582 INFO 20080407 16:43:49,630 upload.TestQueueMDB [2] Got: 619
      WorkManager(2)-153 1810582 INFO 20080407 16:43:49,630 upload.TestQueueMDB [14] Got: 633
      WorkManager(2)-132 1810582 INFO 20080407 16:43:49,630 upload.TestQueueMDB [13] Got: 627
      WorkManager(2)-131 1810582 INFO 20080407 16:43:49,630 upload.TestQueueMDB [13] Got: 620
      WorkManager(2)-148 1810582 INFO 20080407 16:43:49,630 upload.TestQueueMDB [13] Got: 626
      WorkManager(2)-141 1810582 INFO 20080407 16:43:49,630 upload.TestQueueMDB [13] Got: 629
      WorkManager(2)-145 1810582 INFO 20080407 16:43:49,630 upload.TestQueueMDB [13] Got: 632
      WorkManager(2)-140 1810582 INFO 20080407 16:43:49,630 upload.TestQueueMDB [3] Got: 622
      


      MDB:

      /**
       * processes each message from jms queue.
       * @param pMessage the message
       */
       @TransactionAttribute(TransactionAttributeType.REQUIRED)
       public void onMessage(Message pMessage) {
       Long l = null;
       NDC.push(workerCount+"");
       try {
       Thread.sleep(500);
       l = (Long) ((ObjectMessage) pMessage).getObject();
       } catch (JMSException e) {
       LOG.error(e,e);
       } catch (InterruptedException e) {
       LOG.error(e,e);
       }
      
       LOG.info("Got: " + l);
       try {
       pMessage.acknowledge();
       } catch (JMSException e) {
       LOG.error(e);
       }
       NDC.pop();
       }


      TestClient:

      public void testDummyMessage() throws JMSException, NamingException {
      
      
       final TestJmsConHandler jmsCon = new TestJmsConHandler("/queue/testqueue");
      
       LOG.info("Sending message...");
      
       try {
       jmsCon.connect();
       LOG.info("JMS connected ... OK.");
      
       for ( int i = 0; i < 20000; i++) {
       Long l = new Long(i);
       final ObjectMessage m = jmsCon.getSession().createObjectMessage(l);
       LOG.info("JMS Message " + i + " created .... OK.");
       jmsCon.send(m);//
       }
      
       LOG.info("JMS Message sent .... OK.");
       } finally {
       jmsCon.disconnect();
       }
      
      
       }


      *-service.xml file:

      <server>
       <mbean code="org.jboss.mq.server.jmx.Queue"
       name="jboss.mq.destination:service=Queue,name=testqueue">
       <depends optional-attribute-name="DestinationManager">jboss.mq:service=DestinationManager</depends>
       <!-- throw an excpetion when having more than this in the queue -->
       <attribute name="MaxDepth">1000000</attribute>
       <!-- Try to redliver a message when onMessage threw a runtime exeptiuon -->
       <attribute name="RedeliveryLimit">10</attribute>
       <!-- retry the delivery after 10 seconds -->
       <attribute name="RedeliveryDelay">10000</attribute>
       <!--<attribute name="MaximumSize">20</attribute>-->
       </mbean>
      
      </server>