[jboss-remoting-commits] JBoss Remoting SVN: r4349 - in remoting3/trunk: standalone/src/main/java/org/jboss/cx/remoting and 1 other directory.

[jboss-remoting-commits at lists.jboss.org]

Author: david.lloyd at jboss.com
Date: 2008-07-03 13:08:28 -0400 (Thu, 03 Jul 2008)
New Revision: 4349

Modified:
   remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/LocalBasicExampleMain.java
   remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/LocalStreamExampleMain.java
   remoting3/trunk/standalone/src/main/java/org/jboss/cx/remoting/Remoting.java
Log:
Convenience method to cleanly/safely create a client

Modified: remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/LocalBasicExampleMain.java
===================================================================
--- remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/LocalBasicExampleMain.java	2008-07-03 14:19:31 UTC (rev 4348)
+++ remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/LocalBasicExampleMain.java	2008-07-03 17:08:28 UTC (rev 4349)
@@ -19,7 +19,7 @@
         final StringRot13RequestListener listener = new StringRot13RequestListener();
         final Endpoint endpoint = Remoting.createEndpoint("simple");
         try {
-            final Client<String,String> client = endpoint.createClient(listener).getClient();
+            final Client<String,String> client = Remoting.createLocalClient(endpoint, listener);
             try {
                 final String original = "The Secret Message\n";
                 final String result = client.invoke(original);

Modified: remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/LocalStreamExampleMain.java
===================================================================
--- remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/LocalStreamExampleMain.java	2008-07-03 14:19:31 UTC (rev 4348)
+++ remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/LocalStreamExampleMain.java	2008-07-03 17:08:28 UTC (rev 4349)
@@ -25,7 +25,7 @@
         final StreamingRot13RequestListener listener = new StreamingRot13RequestListener();
         final Endpoint endpoint = Remoting.createEndpoint("simple");
         try {
-            final Client<Reader,Reader> client = endpoint.createClient(listener).getClient();
+            final Client<Reader,Reader> client = Remoting.createLocalClient(endpoint, listener);
             try {
                 final String original = "The Secret Message\n";
                 final StringReader originalReader = new StringReader(original);

Modified: remoting3/trunk/standalone/src/main/java/org/jboss/cx/remoting/Remoting.java
===================================================================
--- remoting3/trunk/standalone/src/main/java/org/jboss/cx/remoting/Remoting.java	2008-07-03 14:19:31 UTC (rev 4348)
+++ remoting3/trunk/standalone/src/main/java/org/jboss/cx/remoting/Remoting.java	2008-07-03 17:08:28 UTC (rev 4349)
@@ -3,6 +3,8 @@
 import java.io.IOException;
 import java.util.concurrent.ConcurrentMap;
 import org.jboss.cx.remoting.core.EndpointImpl;
+import org.jboss.cx.remoting.spi.remote.RemoteClientEndpoint;
+import org.jboss.cx.remoting.spi.remote.RemoteServiceEndpoint;
 
 /**
  *
@@ -40,6 +42,24 @@
         }
     }
 
+    public static <I, O> Client<I, O> createLocalClient(Endpoint endpoint, RequestListener<I, O> requestListener) throws RemotingException {
+        final RemoteClientEndpoint<I, O> clientEndpoint = endpoint.createClient(requestListener);
+        try {
+            return clientEndpoint.getClient();
+        } finally {
+            clientEndpoint.autoClose();
+        }
+    }
+
+    public static <I, O> ClientSource<I, O> createLocalClientSource(Endpoint endpoint, RequestListener<I, O> requestListener) throws RemotingException {
+        final RemoteServiceEndpoint<I, O> clientEndpoint = endpoint.createService(requestListener);
+        try {
+            return clientEndpoint.getClientSource();
+        } finally {
+            clientEndpoint.autoClose();
+        }
+    }
+
     // privates
 
     private Remoting() { /* empty */ }