[Design of Messaging on JBoss (Messaging/JBoss)] - Re: intermittent failures i am seeing
by ataylor
Clebert, Ive ran this in a loop for 100's of times withouit failures. can you apply the following patch.
Index: tests/src/org/jboss/messaging/tests/integration/client/ClientSessionStopStartTest.java
| ===================================================================
| --- tests/src/org/jboss/messaging/tests/integration/client/ClientSessionStopStartTest.java (revision 6180)
| +++ tests/src/org/jboss/messaging/tests/integration/client/ClientSessionStopStartTest.java Fri Mar 27 08:15:18 GMT 2009
| @@ -590,10 +590,13 @@
| assertNull(cm);
|
| session.start();
| + System.out.println("consumer = " + consumer);
| cm = consumer.receive(5000);
| assertNotNull(cm);
| + System.out.println("consumer2 = " + consumer2);
| cm = consumer2.receive(5000);
| assertNotNull(cm);
| + System.out.println("consumer3 = " + consumer3);
| cm = consumer3.receive(5000);
| assertNotNull(cm);
| session.close();
| Index: src/main/org/jboss/messaging/core/client/impl/ClientConsumerImpl.java
| ===================================================================
| --- src/main/org/jboss/messaging/core/client/impl/ClientConsumerImpl.java (revision 6173)
| +++ src/main/org/jboss/messaging/core/client/impl/ClientConsumerImpl.java Fri Mar 27 08:15:18 GMT 2009
| @@ -763,6 +763,11 @@
| channel.write(ByteBuffer.wrap(body));
| }
|
| + public String toString()
| + {
| + return "messages in buffer = " + buffer.size();
| + }
| +
| // Inner classes
| // --------------------------------------------------------------------------------
|
|
i would always see
consumer = messages in buffer = 24
| consumer2 = messages in buffer = 24
| consumer3 = messages in buffer = 24
Since ive set the clientwindowsize it should guarantee that all the consumers receive messages and have messages in there buffer.
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4221468#4221468
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4221468
15 years