3 Replies Latest reply on Apr 9, 2008 11:39 AM by adrian.brock

    Problem shutting down persistant JMS queue.

    finix
    finix Apr 7, 2008 11:07 AM

      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>


      • 1525 Views
      • Tags: