[infinispan-commits] Infinispan SVN: r1381 - trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups.

[infinispan-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2010-01-16 10:18:18 -0500 (Sat, 16 Jan 2010)
New Revision: 1381

Modified:
   trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/CommandAwareRpcDispatcher.java
Log:
Removed use of deprecated methods

Modified: trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/CommandAwareRpcDispatcher.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/CommandAwareRpcDispatcher.java	2010-01-15 18:31:09 UTC (rev 1380)
+++ trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/CommandAwareRpcDispatcher.java	2010-01-16 15:18:18 UTC (rev 1381)
@@ -252,7 +252,12 @@
          RspList retval = null;
 
          if (broadcast) {
-            retval = castMessage(dests, constructMessage(buf, null), mode, timeout, false, filter);
+            RequestOptions opts = new RequestOptions();
+            opts.setMode(mode);
+            opts.setTimeout(timeout);
+            opts.setRspFilter(filter);
+            opts.setAnycasting(false);
+            retval = castMessage(dests, constructMessage(buf, null), opts);
          } else {
             Set<Address> targets = new HashSet<Address>(dests); // should sufficiently randomize order.
             RequestOptions opts = new RequestOptions();
@@ -332,7 +337,12 @@
 
                   if (trace)
                      log.trace("Replaying message to ignoring senders: " + ignorers);
-                  RspList responses = castMessage(ignorers, msg, GroupRequest.GET_ALL, timeout, anycasting, filter);
+                  RequestOptions opts = new RequestOptions();
+                  opts.setMode(GroupRequest.GET_ALL);
+                  opts.setTimeout(timeout);
+                  opts.setAnycasting(anycasting);
+                  opts.setRspFilter(filter);
+                  RspList responses = castMessage(ignorers, msg, opts);
                   if (responses != null)
                      retval.putAll(responses);
                }