[jboss-cvs] JBossRemoting/src/tests/org/jboss/test/remoting/callback/pull/blocking ...
Ron Sigal
ron_sigal at yahoo.com
Mon May 21 23:43:15 EDT 2007
User: rsigal
Date: 07/05/21 23:43:15
Modified: src/tests/org/jboss/test/remoting/callback/pull/blocking
Tag: remoting_2_x BlockingPullCallbackTestCase.java
Log:
JBREM-641: Changed ServerInvoker.BLOCK to ServerInvoker.BLOCKING.
Revision Changes Path
No revision
No revision
1.1.2.2 +7 -7 JBossRemoting/src/tests/org/jboss/test/remoting/callback/pull/blocking/Attic/BlockingPullCallbackTestCase.java
(In the diff below, changes in quantity of whitespace are not shown.)
Index: BlockingPullCallbackTestCase.java
===================================================================
RCS file: /cvsroot/jboss/JBossRemoting/src/tests/org/jboss/test/remoting/callback/pull/blocking/Attic/BlockingPullCallbackTestCase.java,v
retrieving revision 1.1.2.1
retrieving revision 1.1.2.2
diff -u -b -r1.1.2.1 -r1.1.2.2
--- BlockingPullCallbackTestCase.java 5 May 2007 07:47:46 -0000 1.1.2.1
+++ BlockingPullCallbackTestCase.java 22 May 2007 03:43:15 -0000 1.1.2.2
@@ -59,7 +59,7 @@
* See JBREM-641.
*
* @author <a href="ron.sigal at jboss.com">Ron Sigal</a>
- * @version $Revision: 1.1.2.1 $
+ * @version $Revision: 1.1.2.2 $
* <p>
* Copyright May 2, 2007
* </p>
@@ -179,7 +179,7 @@
// Test blocking callbacks.
pullerMetadata.clear();
pullerMetadata.put(CALLBACK_DELAY_KEY, Integer.toString(CALLBACK_DELAY));
- pullerMetadata.put(ServerInvoker.BLOCKING_MODE, ServerInvoker.BLOCK);
+ pullerMetadata.put(ServerInvoker.BLOCKING_MODE, ServerInvoker.BLOCKING);
pullerMetadata.put(ServerInvoker.BLOCKING_TIMEOUT, Integer.toString(CALLBACK_DELAY * 2));
puller = new CallbackPuller(client, callbackHandler, pullerMetadata);
puller.start();
@@ -250,7 +250,7 @@
int CALLBACK_DELAY = blockingTimeout - 1000;
Map pullerMetadata = new HashMap();
pullerMetadata.put(CALLBACK_DELAY_KEY, Integer.toString(CALLBACK_DELAY));
- pullerMetadata.put(ServerInvoker.BLOCKING_MODE, ServerInvoker.BLOCK);
+ pullerMetadata.put(ServerInvoker.BLOCKING_MODE, ServerInvoker.BLOCKING);
CallbackPuller puller = new CallbackPuller(client, callbackHandler, pullerMetadata);
puller.start();
Thread.sleep(CALLBACK_DELAY - 1000);
@@ -397,7 +397,7 @@
int CALLBACK_DELAY = serverBlockingTimeout + 1000;
Map pullerMetadata = new HashMap();
pullerMetadata.put(CALLBACK_DELAY_KEY, Integer.toString(CALLBACK_DELAY));
- pullerMetadata.put(ServerInvoker.BLOCKING_MODE, ServerInvoker.BLOCK);
+ pullerMetadata.put(ServerInvoker.BLOCKING_MODE, ServerInvoker.BLOCKING);
pullerMetadata.put(ServerInvoker.BLOCKING_TIMEOUT, Integer.toString(clientBlockingTimeout));
CallbackPuller puller = new CallbackPuller(client, callbackHandler, pullerMetadata);
puller.start();
@@ -517,7 +517,7 @@
SimpleCallbackHandler callbackHandler = new SimpleCallbackHandler();
Map metadata = new HashMap();
metadata.put(CallbackPoller.CALLBACK_POLL_PERIOD, Integer.toString(CALLBACK_DELAY));
- metadata.put(ServerInvoker.BLOCKING_MODE, ServerInvoker.BLOCK);
+ metadata.put(ServerInvoker.BLOCKING_MODE, ServerInvoker.BLOCKING);
client.addListener(callbackHandler, metadata);
log.info("client added callback handler for pull callbacks");
@@ -588,7 +588,7 @@
field.setAccessible(true);
Map callbackPollers = (Map) field.get(client);
final SimpleCallbackHandler callbackHandler = new SimpleCallbackHandler();
- metadata.put(ServerInvoker.BLOCKING_MODE, ServerInvoker.BLOCK);
+ metadata.put(ServerInvoker.BLOCKING_MODE, ServerInvoker.BLOCKING);
client.addListener(callbackHandler, metadata);
assertEquals(1, callbackPollers.size());
CallbackPoller callbackPoller = (CallbackPoller) callbackPollers.values().iterator().next();
@@ -670,7 +670,7 @@
field.setAccessible(true);
Map callbackPollers = (Map) field.get(client);
final SimpleCallbackHandler callbackHandler = new SimpleCallbackHandler();
- metadata.put(ServerInvoker.BLOCKING_MODE, ServerInvoker.BLOCK);
+ metadata.put(ServerInvoker.BLOCKING_MODE, ServerInvoker.BLOCKING);
metadata.put(ServerInvoker.BLOCKING_TIMEOUT, "6000");
client.addListener(callbackHandler, metadata);
assertEquals(1, callbackPollers.size());
More information about the jboss-cvs-commits
mailing list