[jboss-remoting-commits] JBoss Remoting SVN: r3988 - remoting3/trunk/samples/src/main/java/org/jboss/cx/remoting/samples/simple.
jboss-remoting-commits at lists.jboss.org
jboss-remoting-commits at lists.jboss.org
Mon Apr 14 12:48:46 EDT 2008
Author: david.lloyd at 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
More information about the jboss-remoting-commits
mailing list