10:07 a.m.
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>
View the original post :
http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4142102#...
Reply to the post :
http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&a...