[jboss-cvs] JBossRemoting/src/tests/org/jboss/test/remoting/callback/acknowledge ...

[Ron Sigal]

  User: rsigal  
  Date: 07/06/22 03:05:57

  Modified:    src/tests/org/jboss/test/remoting/callback/acknowledge  Tag:
                        remoting_2_x CallbackAcknowledgeTestCase.java
  Log:
  JBREM-641:  Blocking mode is explicitly configured in blocking polling test methods.
  
  Revision  Changes    Path
  No                   revision
  
  
  No                   revision
  
  
  1.2.2.7   +4 -0      JBossRemoting/src/tests/org/jboss/test/remoting/callback/acknowledge/CallbackAcknowledgeTestCase.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: CallbackAcknowledgeTestCase.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossRemoting/src/tests/org/jboss/test/remoting/callback/acknowledge/CallbackAcknowledgeTestCase.java,v
  retrieving revision 1.2.2.6
  retrieving revision 1.2.2.7
  diff -u -b -r1.2.2.6 -r1.2.2.7
  --- CallbackAcknowledgeTestCase.java	22 May 2007 03:42:55 -0000	1.2.2.6
  +++ CallbackAcknowledgeTestCase.java	22 Jun 2007 07:05:57 -0000	1.2.2.7
  @@ -490,6 +490,7 @@
         {
            TestCallbackHandler callbackHandler1 = new TestCallbackHandler(client, 1);
            HashMap metadata = new HashMap();
  +         metadata.put(ServerInvoker.BLOCKING_MODE, ServerInvoker.BLOCKING);
            client.addListener(callbackHandler1, metadata);
            TestCallbackHandler callbackHandler2 = new TestCallbackHandler(client, 2);
            client.addListener(callbackHandler2, metadata);
  @@ -576,6 +577,7 @@
         {
            TestCallbackHandler callbackHandler = new TestCallbackHandler(client);
            HashMap metadata = new HashMap();
  +         metadata.put(ServerInvoker.BLOCKING_MODE, ServerInvoker.BLOCKING);
            client.addListener(callbackHandler, metadata);
            client.addListener(callbackHandler, metadata);
            assertEquals(0, TestInvocationHandler.callbacksAcknowledged);
  @@ -656,6 +658,7 @@
         {
            TestCallbackHandler callbackHandler1 = new TestCallbackHandler();
            HashMap metadata = new HashMap();
  +         metadata.put(ServerInvoker.BLOCKING_MODE, ServerInvoker.BLOCKING);
            client.addListener(callbackHandler1, metadata);
            TestCallbackHandler callbackHandler2 = new TestCallbackHandler();
            client.addListener(callbackHandler2, metadata);
  @@ -733,6 +736,7 @@
         {
            TestCallbackHandler callbackHandler = new TestCallbackHandler();
            HashMap metadata = new HashMap();
  +         metadata.put(ServerInvoker.BLOCKING_MODE, ServerInvoker.BLOCKING);
            client.addListener(callbackHandler, metadata);
            client.addListener(callbackHandler, metadata);
            assertEquals(0, TestInvocationHandler.callbacksAcknowledged);