[jboss-remoting-commits] JBoss Remoting SVN: r3988 - remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple.

Author: david.lloyd(a)jboss.com Date: 2008-04-14 12:48:46 -0400 (Mon, 14 Apr 2008) New Revision: 3988 Added: remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/JrppBasicExampleMain.java remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/JrppStreamExampleMain.java 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/samples/src/main/java/org/jboss/cx/remoting/samples/simple/StreamingRot13RequestListener.java remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/StringRot13RequestListener.java Removed: 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 remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/Rot13RequestListener.java Log: More simple examples Added: remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/JrppBasicExampleMain.java =================================================================== --- remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/JrppBasicExampleMain.java (rev 0) +++ remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/JrppBasicExampleMain.java 2008-04-14 16:48:46 UTC (rev 3988) @@ -0,0 +1,45 @@ +package org.jboss.cx.remoting.samples.simple; + +import java.io.IOException; +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 JrppBasicExampleMain { + + public static void main(String[] args) throws IOException, RemoteExecutionException, URISyntaxException { + Security.addProvider(new Provider()); + final StringRot13RequestListener listener = new StringRot13RequestListener(); + 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<String,String> context = session.getRootContext(); + try { + final String original = "The Secret Message\n"; + final String result = context.invoke(original); + System.out.printf("The secret message \"%s\" became \"%s\"!\n", original.trim(), result.trim()); + } finally { + context.close(); + } + } finally { + session.close(); + } + } finally { + endpoint.close(); + } + + } +} \ No newline at end of file Deleted: 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 2008-04-14 16:37:33 UTC (rev 3987) +++ remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/JrppMain.java 2008-04-14 16:48:46 UTC (rev 3988) @@ -1,63 +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.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/JrppStreamExampleMain.java (from rev 3985, 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/JrppStreamExampleMain.java (rev 0) +++ remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/JrppStreamExampleMain.java 2008-04-14 16:48:46 UTC (rev 3988) @@ -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 JrppStreamExampleMain { + + public static void main(String[] args) throws IOException, RemoteExecutionException, URISyntaxException { + Security.addProvider(new Provider()); + final StreamingRot13RequestListener listener = new StreamingRot13RequestListener(); + 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(); + } + + } +} Added: 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 (rev 0) +++ remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/LocalBasicExampleMain.java 2008-04-14 16:48:46 UTC (rev 3988) @@ -0,0 +1,33 @@ +package org.jboss.cx.remoting.samples.simple; + +import java.io.IOException; +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.core.security.sasl.Provider; + +/** + * + */ +public final class LocalBasicExampleMain { + + public static void main(String[] args) throws IOException, RemoteExecutionException { + Security.addProvider(new Provider()); + final StringRot13RequestListener listener = new StringRot13RequestListener(); + final Endpoint endpoint = Remoting.createEndpoint("simple", listener); + try { + final Context<String,String> context = endpoint.createContext(listener); + try { + final String original = "The Secret Message\n"; + final String result = context.invoke(original); + System.out.printf("The secret message \"%s\" became \"%s\"!\n", original.trim(), result.trim()); + } finally { + context.close(); + } + } finally { + endpoint.close(); + } + } +} \ No newline at end of file Deleted: remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/LocalMain.java =================================================================== --- remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/LocalMain.java 2008-04-14 16:37:33 UTC (rev 3987) +++ remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/LocalMain.java 2008-04-14 16:48:46 UTC (rev 3988) @@ -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 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(); - } - } -} Copied: remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/LocalStreamExampleMain.java (from rev 3985, remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/LocalMain.java) =================================================================== --- remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/LocalStreamExampleMain.java (rev 0) +++ remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/LocalStreamExampleMain.java 2008-04-14 16:48:46 UTC (rev 3988) @@ -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.RemoteExecutionException; +import org.jboss.cx.remoting.Remoting; +import org.jboss.cx.remoting.core.security.sasl.Provider; + +/** + * + */ +public final class LocalStreamExampleMain { + + public static void main(String[] args) throws IOException, RemoteExecutionException { + Security.addProvider(new Provider()); + final StreamingRot13RequestListener listener = new StreamingRot13RequestListener(); + 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/Rot13RequestListener.java =================================================================== --- remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/Rot13RequestListener.java 2008-04-14 16:37:33 UTC (rev 3987) +++ remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/Rot13RequestListener.java 2008-04-14 16:48:46 UTC (rev 3988) @@ -1,57 +0,0 @@ -package org.jboss.cx.remoting.samples.simple; - -import java.io.Reader; -import java.io.IOException; -import org.jboss.cx.remoting.AbstractRequestListener; -import org.jboss.cx.remoting.RequestContext; -import org.jboss.cx.remoting.RemoteExecutionException; -import org.jboss.cx.remoting.RemotingException; - -/** - * - */ -public final class Rot13RequestListener extends AbstractRequestListener<Reader, Reader> { - - public void handleRequest(final RequestContext<Reader> readerRequestContext, final Reader request) throws RemoteExecutionException, InterruptedException { - try { - readerRequestContext.sendReply(new Reader() { - - public int read() throws IOException { - final int i = request.read(); - if (i > 0) { - return rot13((char) i); - } else { - return i; - } - } - - public int read(final char cbuf[], final int off, final int len) throws IOException { - for (int i = 0; i < len; i++) { - final int c = read(); - if (c == -1) { - return i; - } - cbuf[off + i] = (char) c; - } - return len; - } - - public void close() throws IOException { - request.close(); - } - }); - } catch (RemotingException e) { - throw new RemoteExecutionException("Failed to send reply", e); - } - } - - private char rot13(final char i) { - if (i >= 'A' && i <= 'M' || i >= 'a' && i <= 'm') { - return (char) (i + 13); - } else if (i >= 'N' && i <= 'Z' || i >= 'n' && i <= 'z') { - return (char) (i - 13); - } else { - return i; - } - } -} Copied: remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/StreamingRot13RequestListener.java (from rev 3985, remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/Rot13RequestListener.java) =================================================================== --- remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/StreamingRot13RequestListener.java (rev 0) +++ remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/StreamingRot13RequestListener.java 2008-04-14 16:48:46 UTC (rev 3988) @@ -0,0 +1,57 @@ +package org.jboss.cx.remoting.samples.simple; + +import java.io.IOException; +import java.io.Reader; +import org.jboss.cx.remoting.AbstractRequestListener; +import org.jboss.cx.remoting.RemoteExecutionException; +import org.jboss.cx.remoting.RemotingException; +import org.jboss.cx.remoting.RequestContext; + +/** + * + */ +public final class StreamingRot13RequestListener extends AbstractRequestListener<Reader, Reader> { + + public void handleRequest(final RequestContext<Reader> readerRequestContext, final Reader request) throws RemoteExecutionException, InterruptedException { + try { + readerRequestContext.sendReply(new Reader() { + + public int read() throws IOException { + final int i = request.read(); + if (i > 0) { + return rot13((char) i); + } else { + return i; + } + } + + public int read(final char cbuf[], final int off, final int len) throws IOException { + for (int i = 0; i < len; i++) { + final int c = read(); + if (c == -1) { + return i; + } + cbuf[off + i] = (char) c; + } + return len; + } + + public void close() throws IOException { + request.close(); + } + }); + } catch (RemotingException e) { + throw new RemoteExecutionException("Failed to send reply", e); + } + } + + private char rot13(final char i) { + if (i >= 'A' && i <= 'M' || i >= 'a' && i <= 'm') { + return (char) (i + 13); + } else if (i >= 'N' && i <= 'Z' || i >= 'n' && i <= 'z') { + return (char) (i - 13); + } else { + return i; + } + } +} Added: remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/StringRot13RequestListener.java =================================================================== --- remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/StringRot13RequestListener.java (rev 0) +++ remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple/StringRot13RequestListener.java 2008-04-14 16:48:46 UTC (rev 3988) @@ -0,0 +1,34 @@ +package org.jboss.cx.remoting.samples.simple; + +import org.jboss.cx.remoting.AbstractRequestListener; +import org.jboss.cx.remoting.RemoteExecutionException; +import org.jboss.cx.remoting.RemotingException; +import org.jboss.cx.remoting.RequestContext; + +/** + * + */ +public final class StringRot13RequestListener extends AbstractRequestListener<String, String> { + + public void handleRequest(final RequestContext<String> readerRequestContext, final String request) throws RemoteExecutionException, InterruptedException { + try { + StringBuilder b = new StringBuilder(request.length()); + for (int i = 0; i < request.length(); i ++) { + b.append(rot13(request.charAt(i))); + } + readerRequestContext.sendReply(b.toString()); + } catch (RemotingException e) { + throw new RemoteExecutionException("Failed to send reply", e); + } + } + + private char rot13(final char i) { + if (i >= 'A' && i <= 'M' || i >= 'a' && i <= 'm') { + return (char) (i + 13); + } else if (i >= 'N' && i <= 'Z' || i >= 'n' && i <= 'z') { + return (char) (i - 13); + } else { + return i; + } + } +} \ No newline at end of file