[jboss-remoting-commits] JBoss Remoting SVN: r3984 - in remoting3/trunk: samples/src/main/java/org/jboss/cx/remoting/samples/simple and 1 other directory.
jboss-remoting-commits at lists.jboss.org
jboss-remoting-commits at lists.jboss.org
Mon Apr 14 09:32:23 EDT 2008
Author: david.lloyd at jboss.com
Date: 2008-04-14 09:32:23 -0400 (Mon, 14 Apr 2008)
New Revision: 3984
Added:
remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/JrppMain.java
remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/LocalMain.java
Removed:
remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/Main.java
Modified:
remoting3/trunk/build.xml
Log:
Add JRPP example
Modified: remoting3/trunk/build.xml
===================================================================
--- remoting3/trunk/build.xml 2008-04-14 13:25:11 UTC (rev 3983)
+++ remoting3/trunk/build.xml 2008-04-14 13:32:23 UTC (rev 3984)
@@ -774,6 +774,7 @@
<path refid="api.classpath"/>
<path refid="srp.classpath"/>
<path refid="standalone.classpath"/>
+ <path refid="util.classpath"/>
</classpath>
</javac>
<touch file="samples/target/main/.lastcompile" verbose="false"/>
@@ -783,7 +784,7 @@
<delete dir="samples/target"/>
</target>
- <target name="samples" description="Build the samples module" depends="api,srp,standalone,samples.compile">
+ <target name="samples" description="Build the samples module" depends="api,srp,standalone,util,samples.compile">
<path id="samples.classpath">
<pathelement location="samples/target/main/classes"/>
</path>
Added: remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/JrppMain.java
===================================================================
--- remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/JrppMain.java (rev 0)
+++ remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/JrppMain.java 2008-04-14 13:32:23 UTC (rev 3984)
@@ -0,0 +1,63 @@
+package org.jboss.cx.remoting.samples.simple;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.Reader;
+import java.io.StringReader;
+import java.net.InetSocketAddress;
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.security.Security;
+import org.jboss.cx.remoting.Context;
+import org.jboss.cx.remoting.Endpoint;
+import org.jboss.cx.remoting.RemoteExecutionException;
+import org.jboss.cx.remoting.Remoting;
+import org.jboss.cx.remoting.Session;
+import org.jboss.cx.remoting.core.security.sasl.Provider;
+import org.jboss.cx.remoting.util.AttributeMap;
+
+/**
+ *
+ */
+public final class JrppMain {
+
+ public static void main(String[] args) throws IOException, RemoteExecutionException, URISyntaxException {
+ Security.addProvider(new Provider());
+ final Rot13RequestListener listener = new Rot13RequestListener();
+ final Endpoint endpoint = Remoting.createEndpoint("simple", listener);
+ try {
+ Remoting.addJrppServer(endpoint, new InetSocketAddress(12345), AttributeMap.EMPTY);
+ Session session = endpoint.openSession(new URI("jrpp://localhost:12345"), AttributeMap.EMPTY);
+ try {
+ final Context<Reader,Reader> context = session.getRootContext();
+ try {
+ final String original = "The Secret Message\n";
+ final StringReader originalReader = new StringReader(original);
+ try {
+ final Reader reader = context.send(originalReader).get();
+ try {
+ final BufferedReader bufferedReader = new BufferedReader(reader);
+ try {
+ final String secretLine = bufferedReader.readLine();
+ System.out.printf("The secret message \"%s\" became \"%s\"!\n", original.trim(), secretLine);
+ } finally {
+ bufferedReader.close();
+ }
+ } finally {
+ reader.close();
+ }
+ } finally {
+ originalReader.close();
+ }
+ } finally {
+ context.close();
+ }
+ } finally {
+ session.close();
+ }
+ } finally {
+ endpoint.close();
+ }
+
+ }
+}
Copied: remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/LocalMain.java (from rev 3983, remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/Main.java)
===================================================================
--- remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/LocalMain.java (rev 0)
+++ remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/LocalMain.java 2008-04-14 13:32:23 UTC (rev 3984)
@@ -0,0 +1,51 @@
+package org.jboss.cx.remoting.samples.simple;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.Reader;
+import java.io.StringReader;
+import java.security.Security;
+import org.jboss.cx.remoting.Context;
+import org.jboss.cx.remoting.Endpoint;
+import org.jboss.cx.remoting.Remoting;
+import org.jboss.cx.remoting.RemoteExecutionException;
+import org.jboss.cx.remoting.core.security.sasl.Provider;
+
+/**
+ *
+ */
+public final class LocalMain {
+
+ public static void main(String[] args) throws IOException, RemoteExecutionException {
+ Security.addProvider(new Provider());
+ final Rot13RequestListener listener = new Rot13RequestListener();
+ final Endpoint endpoint = Remoting.createEndpoint("simple", listener);
+ try {
+ final Context<Reader,Reader> context = endpoint.createContext(listener);
+ try {
+ final String original = "The Secret Message\n";
+ final StringReader originalReader = new StringReader(original);
+ try {
+ final Reader reader = context.send(originalReader).get();
+ try {
+ final BufferedReader bufferedReader = new BufferedReader(reader);
+ try {
+ final String secretLine = bufferedReader.readLine();
+ System.out.printf("The secret message \"%s\" became \"%s\"!\n", original.trim(), secretLine);
+ } finally {
+ bufferedReader.close();
+ }
+ } finally {
+ reader.close();
+ }
+ } finally {
+ originalReader.close();
+ }
+ } finally {
+ context.close();
+ }
+ } finally {
+ endpoint.close();
+ }
+ }
+}
Deleted: remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/Main.java
===================================================================
--- remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/Main.java 2008-04-14 13:25:11 UTC (rev 3983)
+++ remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/Main.java 2008-04-14 13:32:23 UTC (rev 3984)
@@ -1,51 +0,0 @@
-package org.jboss.cx.remoting.samples.simple;
-
-import java.io.BufferedReader;
-import java.io.IOException;
-import java.io.Reader;
-import java.io.StringReader;
-import java.security.Security;
-import org.jboss.cx.remoting.Context;
-import org.jboss.cx.remoting.Endpoint;
-import org.jboss.cx.remoting.Remoting;
-import org.jboss.cx.remoting.RemoteExecutionException;
-import org.jboss.cx.remoting.core.security.sasl.Provider;
-
-/**
- *
- */
-public final class Main {
-
- public static void main(String[] args) throws IOException, RemoteExecutionException {
- Security.addProvider(new Provider());
- final Rot13RequestListener listener = new Rot13RequestListener();
- final Endpoint endpoint = Remoting.createEndpoint("simple", listener);
- try {
- final Context<Reader,Reader> context = endpoint.createContext(listener);
- try {
- final String original = "The Secret Message\n";
- final StringReader originalReader = new StringReader(original);
- try {
- final Reader reader = context.send(originalReader).get();
- try {
- final BufferedReader bufferedReader = new BufferedReader(reader);
- try {
- final String secretLine = bufferedReader.readLine();
- System.out.printf("The secret message \"%s\" became \"%s\"!\n", original.trim(), secretLine);
- } finally {
- bufferedReader.close();
- }
- } finally {
- reader.close();
- }
- } finally {
- originalReader.close();
- }
- } finally {
- context.close();
- }
- } finally {
- endpoint.close();
- }
- }
-}
More information about the jboss-remoting-commits
mailing list