[jboss-dev-forums] [Design of Messaging on JBoss (Messaging/JBoss)] - Re: intermittent failures i am seeing

[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