[jboss-remoting-commits] JBoss Remoting SVN: r4608 - in remoting3/trunk: transporter and 7 other directories.
jboss-remoting-commits at lists.jboss.org
jboss-remoting-commits at lists.jboss.org
Wed Oct 22 19:47:57 EDT 2008
Author: david.lloyd at jboss.com
Date: 2008-10-22 19:47:56 -0400 (Wed, 22 Oct 2008)
New Revision: 4608
Added:
remoting3/trunk/transporter/
remoting3/trunk/transporter/src/
remoting3/trunk/transporter/src/main/
remoting3/trunk/transporter/src/main/java/
remoting3/trunk/transporter/src/main/java/org/
remoting3/trunk/transporter/src/main/java/org/jboss/
remoting3/trunk/transporter/src/main/java/org/jboss/remoting/
remoting3/trunk/transporter/src/main/java/org/jboss/remoting/transporter/
remoting3/trunk/transporter/src/main/java/org/jboss/remoting/transporter/Transporter.java
remoting3/trunk/transporter/src/main/java/org/jboss/remoting/transporter/TransporterInvocation.java
remoting3/trunk/transporter/src/main/java/org/jboss/remoting/transporter/TransporterInvocationHandler.java
remoting3/trunk/transporter/src/main/java/org/jboss/remoting/transporter/TransporterRequestListener.java
remoting3/trunk/transporter/src/main/java/org/jboss/remoting/transporter/package-info.java
Modified:
remoting3/trunk/build.xml
Log:
Add transporters (for Ron:)
Modified: remoting3/trunk/build.xml
===================================================================
--- remoting3/trunk/build.xml 2008-10-22 22:01:55 UTC (rev 4607)
+++ remoting3/trunk/build.xml 2008-10-22 23:47:56 UTC (rev 4608)
@@ -503,189 +503,6 @@
</path>
</target>
- <!-- http module -->
-
- <target name="http.compile.depcheck">
- <mkdir dir="http/target/main"/>
- <uptodate property="http.compile.uptodate" targetfile="http/target/main/.lastcompile">
- <srcfiles dir="http/src/main/java">
- <include name="**/"/>
- <include name="**/*.java"/>
- <exclude name="**/.*"/>
- </srcfiles>
- </uptodate>
- </target>
-
- <target name="http.compile" depends="http.compile.depcheck" unless="http.compile.uptodate">
- <mkdir dir="http/target/main/classes"/>
- <javac
- source="${javac.source}"
- target="${javac.target}"
- srcdir="http/src/main/java"
- destdir="http/target/main/classes"
- debug="true">
- <compilerarg value="-Xlint:unchecked"/>
- <classpath>
- <path refid="api.classpath"/>
- <path refid="util.classpath"/>
- </classpath>
- </javac>
- <touch file="http/target/main/.lastcompile" verbose="false"/>
- </target>
-
- <target name="http.clean">
- <delete dir="http/target"/>
- </target>
-
- <target name="http" description="Build the http module" depends="api,util,http.compile">
- <path id="http.classpath">
- <pathelement location="http/target/main/classes"/>
- </path>
- </target>
-
- <!-- http-se6 module -->
-
- <target name="http-se6.httpserver.builtin-check">
- <condition property="http-se6.httpserver.builtin">
- <available classname="com.sun.http.HttpServer"/>
- </condition>
- </target>
-
- <target name="http-se6.httpserver.classpath.false" depends="http-se6.httpserver.builtin-check" unless="http-se6.httpserver.builtin">
- <path id="httpserver.classpath">
- <pathelement location="${lib.sun-httpserver.local}"/>
- </path>
- </target>
-
- <target name="http-se6.httpserver.classpath.true" depends="http-se6.httpserver.builtin-check" if="http-se6.httpserver.builtin">
- <path id="httpserver.classpath"/>
- </target>
-
- <target name="http-se6.httpserver.classpath" depends="http-se6.httpserver.classpath.false,http-se6.httpserver.classpath.true"/>
-
- <target name="http-se6.compile.depcheck">
- <mkdir dir="http-se6/target/main"/>
- <uptodate property="http-se6.compile.uptodate" targetfile="http-se6/target/main/.lastcompile">
- <srcfiles dir="http-se6/src/main/java">
- <include name="**/"/>
- <include name="**/*.java"/>
- <exclude name="**/.*"/>
- </srcfiles>
- </uptodate>
- </target>
-
- <target name="http-se6.compile" depends="http-se6.compile.depcheck,http-se6.httpserver.classpath" unless="http-se6.compile.uptodate">
- <mkdir dir="http-se6/target/main/classes"/>
- <javac
- source="${javac.source}"
- target="${javac.target}"
- srcdir="http-se6/src/main/java"
- destdir="http-se6/target/main/classes"
- debug="true">
- <compilerarg value="-Xlint:unchecked"/>
- <classpath>
- <path refid="api.classpath"/>
- <path refid="http.classpath"/>
- <path refid="util.classpath"/>
- <path refid="httpserver.classpath"/>
- </classpath>
- </javac>
- <touch file="http-se6/target/main/.lastcompile" verbose="false"/>
- </target>
-
- <target name="http-se6.clean">
- <delete dir="http-se6/target"/>
- </target>
-
- <target name="http-se6" description="Build the http-se6 module" depends="lib.sun-httpserver,api,http,util,http-se6.compile">
- <path id="http-se6.classpath">
- <pathelement location="http-se6/target/main/classes"/>
- </path>
- </target>
-
- <!-- http-servlet module -->
-
- <target name="http-servlet.compile.depcheck">
- <mkdir dir="http-servlet/target/main"/>
- <uptodate property="http-servlet.compile.uptodate" targetfile="http-servlet/target/main/.lastcompile">
- <srcfiles dir="http-servlet/src/main/java">
- <include name="**/"/>
- <include name="**/*.java"/>
- <exclude name="**/.*"/>
- </srcfiles>
- </uptodate>
- </target>
-
- <target name="http-servlet.compile" depends="http-servlet.compile.depcheck" unless="http-servlet.compile.uptodate">
- <mkdir dir="http-servlet/target/main/classes"/>
- <javac
- source="${javac.source}"
- target="${javac.target}"
- srcdir="http-servlet/src/main/java"
- destdir="http-servlet/target/main/classes"
- debug="true">
- <compilerarg value="-Xlint:unchecked"/>
- <classpath>
- <path refid="api.classpath"/>
- <path refid="http.classpath"/>
- <path refid="util.classpath"/>
- <pathelement location="${lib.servlet.local}"/>
- </classpath>
- </javac>
- <touch file="http-servlet/target/main/.lastcompile" verbose="false"/>
- </target>
-
- <target name="http-servlet.clean">
- <delete dir="http-servlet/target"/>
- </target>
-
- <target name="http-servlet" description="Build the http-servlet module" depends="api,http,util,lib.servlet,http-servlet.compile">
- <path id="http-servlet.classpath">
- <pathelement location="http-servlet/target/main/classes"/>
- </path>
- </target>
-
- <!-- http-urlconnection module -->
-
- <target name="http-urlconnection.compile.depcheck">
- <mkdir dir="http-urlconnection/target/main"/>
- <uptodate property="http-urlconnection.compile.uptodate" targetfile="http-urlconnection/target/main/.lastcompile">
- <srcfiles dir="http-urlconnection/src/main/java">
- <include name="**/"/>
- <include name="**/*.java"/>
- <exclude name="**/.*"/>
- </srcfiles>
- </uptodate>
- </target>
-
- <target name="http-urlconnection.compile" depends="http-urlconnection.compile.depcheck" unless="http-urlconnection.compile.uptodate">
- <mkdir dir="http-urlconnection/target/main/classes"/>
- <javac
- source="${javac.source}"
- target="${javac.target}"
- srcdir="http-urlconnection/src/main/java"
- destdir="http-urlconnection/target/main/classes"
- debug="true">
- <compilerarg value="-Xlint:unchecked"/>
- <classpath>
- <path refid="api.classpath"/>
- <path refid="http.classpath"/>
- <path refid="util.classpath"/>
- </classpath>
- </javac>
- <touch file="http-urlconnection/target/main/.lastcompile" verbose="false"/>
- </target>
-
- <target name="http-urlconnection.clean">
- <delete dir="http-urlconnection/target"/>
- </target>
-
- <target name="http-urlconnection" description="Build the http-urlconnection module" depends="api,http,util,http-urlconnection.compile">
- <path id="http-urlconnection.classpath">
- <pathelement location="http-urlconnection/target/main/classes"/>
- </path>
- </target>
-
<!-- mc-deployers module -->
<target name="mc-deployers.compile.depcheck">
@@ -996,7 +813,6 @@
</path>
</target>
-
<!-- samples module -->
<target name="samples.compile.depcheck">
@@ -1021,7 +837,6 @@
<compilerarg value="-Xlint:unchecked"/>
<classpath>
<path refid="api.classpath"/>
- <path refid="srp.classpath"/>
<path refid="standalone.classpath"/>
<path refid="util.classpath"/>
<pathelement location="${lib.xnio-api.local}"/>
@@ -1034,88 +849,12 @@
<delete dir="samples/target"/>
</target>
- <target name="samples" description="Build the samples module" depends="api,srp,standalone,util,samples.compile">
+ <target name="samples" description="Build the samples module" depends="api,standalone,util,samples.compile">
<path id="samples.classpath">
<pathelement location="samples/target/main/classes"/>
</path>
</target>
- <!-- sasl-null module -->
-
- <target name="sasl-null.compile.depcheck">
- <mkdir dir="sasl-null/target/main"/>
- <uptodate property="sasl-null.compile.uptodate" targetfile="sasl-null/target/main/.lastcompile">
- <srcfiles dir="sasl-null/src/main/java">
- <include name="**/"/>
- <include name="**/*.java"/>
- <exclude name="**/.*"/>
- </srcfiles>
- </uptodate>
- </target>
-
- <target name="sasl-null.compile" depends="sasl-null.compile.depcheck" unless="sasl-null.compile.uptodate">
- <mkdir dir="sasl-null/target/main/classes"/>
- <javac
- source="${javac.source}"
- target="${javac.target}"
- srcdir="sasl-null/src/main/java"
- destdir="sasl-null/target/main/classes"
- debug="true">
- <compilerarg value="-Xlint:unchecked"/>
- </javac>
- <touch file="sasl-null/target/main/.lastcompile" verbose="false"/>
- </target>
-
- <target name="sasl-null.clean">
- <delete dir="sasl-null/target"/>
- </target>
-
- <target name="sasl-null" description="Build the sasl-null module" depends="sasl-null.compile">
- <path id="sasl-null.classpath">
- <pathelement location="sasl-null/target/main/classes"/>
- </path>
- </target>
-
- <!-- srp module -->
-
- <target name="srp.compile.depcheck">
- <mkdir dir="srp/target/main"/>
- <uptodate property="srp.compile.uptodate" targetfile="srp/target/main/.lastcompile">
- <srcfiles dir="srp/src/main/java">
- <include name="**/"/>
- <include name="**/*.java"/>
- <exclude name="**/.*"/>
- </srcfiles>
- </uptodate>
- </target>
-
- <target name="srp.compile" depends="srp.compile.depcheck" unless="srp.compile.uptodate">
- <mkdir dir="srp/target/main/classes"/>
- <javac
- source="${javac.source}"
- target="${javac.target}"
- srcdir="srp/src/main/java"
- destdir="srp/target/main/classes"
- debug="true">
- <compilerarg value="-Xlint:unchecked"/>
- <classpath>
- <path refid="util.classpath"/>
- <pathelement location="${lib.xnio-api.local}"/>
- </classpath>
- </javac>
- <touch file="srp/target/main/.lastcompile" verbose="false"/>
- </target>
-
- <target name="srp.clean">
- <delete dir="srp/target"/>
- </target>
-
- <target name="srp" description="Build the SRP SASL module" depends="util,srp.compile">
- <path id="srp.classpath">
- <pathelement location="srp/target/main/classes"/>
- </path>
- </target>
-
<!-- standalone module -->
<target name="standalone.compile.depcheck">
@@ -1198,85 +937,43 @@
</path>
</target>
- <!-- tools module -->
+ <!-- transporter module -->
- <target name="tools.compile.depcheck">
- <mkdir dir="tools/target/main"/>
- <uptodate property="tools.compile.uptodate" targetfile="tools/target/main/.lastcompile">
- <srcfiles dir="tools/src/main/java">
+ <target name="transporter.compile.depcheck">
+ <mkdir dir="transporter/target/main"/>
+ <uptodate property="transporter.compile.uptodate" targetfile="transporter/target/main/.lastcompile">
+ <srcfiles dir="transporter/src/main/java">
<include name="**/"/>
<include name="**/*.java"/>
<exclude name="**/.*"/>
</srcfiles>
</uptodate>
- <condition property="tools.supported">
- <available classname="java.io.Console"/>
- </condition>
</target>
- <target name="tools.compile" depends="tools.compile.depcheck" unless="tools.compile.uptodate" if="tools.supported">
- <mkdir dir="tools/target/main/classes"/>
+ <target name="transporter.compile" depends="transporter.compile.depcheck" unless="transporter.compile.uptodate">
+ <mkdir dir="transporter/target/main/classes"/>
<javac
source="${javac.source}"
target="${javac.target}"
- srcdir="tools/src/main/java"
- destdir="tools/target/main/classes"
+ srcdir="transporter/src/main/java"
+ destdir="transporter/target/main/classes"
debug="true">
<compilerarg value="-Xlint:unchecked"/>
<classpath>
- <path refid="srp.classpath"/>
- <path refid="util.classpath"/>
- </classpath>
- </javac>
- <touch file="tools/target/main/.lastcompile" verbose="false"/>
- </target>
-
- <target name="tools.clean">
- <delete dir="tools/target"/>
- </target>
-
- <target name="tools" description="Build the tools module" depends="srp,util,tools.compile">
- <path id="tools.classpath">
- <pathelement location="tools/target/main/classes"/>
- </path>
- </target>
-
- <!-- transaction module -->
-
- <target name="transaction.compile.depcheck">
- <mkdir dir="transaction/target/main"/>
- <uptodate property="transaction.compile.uptodate" targetfile="transaction/target/main/.lastcompile">
- <srcfiles dir="transaction/src/main/java">
- <include name="**/"/>
- <include name="**/*.java"/>
- <exclude name="**/.*"/>
- </srcfiles>
- </uptodate>
- </target>
-
- <target name="transaction.compile" depends="transaction.compile.depcheck" unless="transaction.compile.uptodate">
- <mkdir dir="transaction/target/main/classes"/>
- <javac
- source="${javac.source}"
- target="${javac.target}"
- srcdir="transaction/src/main/java"
- destdir="transaction/target/main/classes"
- debug="true">
- <compilerarg value="-Xlint:unchecked"/>
- <classpath>
<path refid="api.classpath"/>
+ <pathelement location="${lib.xnio-api.local}"/>
</classpath>
</javac>
- <touch file="transaction/target/main/.lastcompile" verbose="false"/>
+ <touch file="transporter/target/main/.lastcompile" verbose="false"/>
</target>
- <target name="transaction.clean">
- <delete dir="transaction/target"/>
+ <target name="transporter.clean">
+ <delete dir="transporter/target"/>
</target>
- <target name="transaction" description="Build the transaction module" depends="api,transaction.compile">
- <path id="transaction.classpath">
- <pathelement location="transaction/target/main/classes"/>
+ <target name="transporter" description="Build the transporter module" depends="api,lib.xnio-api,transporter.compile">
+ <path id="transporter.classpath">
+ <pathelement location="transporter/target/main/classes"/>
</path>
</target>
@@ -1361,7 +1058,7 @@
<!-- JARS - Keep in alpha order by jar name -->
<!-- ============================================== -->
- <target name="api-jar" description="Build the API JAR" depends="api,util,version">
+ <target name="api-jar" description="Build the API JAR" depends="api,transporter,util,version">
<delete file="jboss-remoting-api.jar"/>
<jar jarfile="jboss-remoting-api.jar">
<manifest>
@@ -1378,6 +1075,9 @@
<zipfileset dir="api/target/main/classes">
<include name="**/*.class"/>
</zipfileset>
+ <zipfileset dir="transporter/target/main/classes">
+ <include name="**/*.class"/>
+ </zipfileset>
<zipfileset dir="util/target/main/classes">
<include name="**/*.class"/>
</zipfileset>
@@ -1407,7 +1107,7 @@
</jar>
</target>
- <target name="standalone-jar" description="Build the standalone JAR" depends="api,core,srp,standalone,util,version">
+ <target name="standalone-jar" description="Build the standalone JAR" depends="api,core,standalone,util,version">
<delete file="jboss-remoting-standalone.jar"/>
<jar jarfile="jboss-remoting-standalone.jar">
<manifest>
@@ -1450,6 +1150,7 @@
<doclet name="${lib.apiviz.doclet}" path="${lib.apiviz.local}"/>
<packageset dir="api/src/main/java"/>
<packageset dir="standalone/src/main/java"/>
+ <packageset dir="transporter/src/main/java"/>
<packageset dir="util/src/main/java"/>
<doctitle><![CDATA[<h1>JBoss Remoting 3</h1>]]></doctitle>
<bottom><![CDATA[<i>Copyright © 2008 JBoss, a division of Red Hat, Inc.</i>]]></bottom>
@@ -1460,6 +1161,7 @@
<path refid="core.classpath"/>
<path refid="api.classpath"/>
<path refid="standalone.classpath"/>
+ <path refid="transporter.classpath"/>
<path refid="util.classpath"/>
<pathelement location="${lib.xnio-api.local}"/>
<pathelement location="${lib.marshalling-api.local}"/>
@@ -1472,16 +1174,10 @@
<!-- core -->
- <target name="all-core" description="Build all core targets" depends="api,compat,core,mc-deployers,protocol.basic,protocol.multiplex,samples,standalone,testing-support,tools,util"/>
+ <target name="all-core" description="Build all core targets" depends="api,compat,core,mc-deployers,protocol.basic,protocol.multiplex,samples,standalone,testing-support,transporter,util"/>
- <target name="clean-core" description="Clean all core targets" depends="api.clean,compat.clean,core.clean,mc-deployers.clean,protocol.basic.clean,protocol.multiplex.clean,samples.clean,standalone.clean,testing-support.clean,tools.clean,util.clean"/>
+ <target name="clean-core" description="Clean all core targets" depends="api.clean,compat.clean,core.clean,mc-deployers.clean,protocol.basic.clean,protocol.multiplex.clean,samples.clean,standalone.clean,testing-support.clean,transporter.clean,util.clean"/>
- <!-- http -->
-
- <target name="all-http" description="Build all HTTP targets" depends="http,http-se6,http-servlet,http-urlconnection"/>
-
- <target name="clean-http" description="Clean all HTTP targets" depends="http.clean,http-se6.clean,http-servlet.clean,http-urlconnection.clean"/>
-
<!-- JARs: These should be the third-to-last targets in the file -->
<target name="all-jars" description="Build all the JARs" depends="api-jar,core-jar,standalone-jar"/>
@@ -1494,7 +1190,7 @@
<target name="all" description="Build everything" depends="all-core,all-jars,api-javadoc"/>
- <target name="clean" description="Clean out all build files" depends="clean-core,clean-http,version.clean,srp.clean"/>
+ <target name="clean" description="Clean out all build files" depends="clean-core,version.clean"/>
<target name="test" description="Run all tests" depends="api.test,core.test,protocol.basic.test,protocol.multiplex.test"/>
Added: remoting3/trunk/transporter/src/main/java/org/jboss/remoting/transporter/Transporter.java
===================================================================
--- remoting3/trunk/transporter/src/main/java/org/jboss/remoting/transporter/Transporter.java (rev 0)
+++ remoting3/trunk/transporter/src/main/java/org/jboss/remoting/transporter/Transporter.java 2008-10-22 23:47:56 UTC (rev 4608)
@@ -0,0 +1,75 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2008, JBoss Inc., and individual contributors as indicated
+ * by the @authors tag. See the copyright.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+
+package org.jboss.remoting.transporter;
+
+import org.jboss.remoting.Endpoint;
+import org.jboss.remoting.Client;
+import org.jboss.remoting.spi.remote.RequestHandler;
+import org.jboss.remoting.spi.remote.Handle;
+import org.jboss.xnio.IoUtils;
+import java.io.IOException;
+import java.lang.reflect.Proxy;
+
+/**
+ * A static class which can be used to create transporter proxies.
+ */
+public final class Transporter {
+
+ private Transporter() {
+ }
+
+ /**
+ * Create a transporter for an object instance. The given type must be an interface type. The returned object
+ * is a serializable proxy that can be sent to other endpoints as a part of a request or a reply.
+ *
+ * @param endpoint the endpoint to anchor the transporter to
+ * @param interfaceType the type of the interface to use
+ * @param instance the instance to which invocations will be sent
+ * @return a transporter proxy
+ * @throws IOException if an error occurs
+ */
+ public static <T> T createTransporter(Endpoint endpoint, Class<T> interfaceType, T instance) throws IOException {
+ boolean ok = false;
+ final Handle<RequestHandler> requestHandlerHandle = endpoint.createRequestHandler(new TransporterRequestListener<T>(instance));
+ try {
+ final Client<TransporterInvocation,Object> client = endpoint.createClient(requestHandlerHandle.getResource());
+ try {
+ requestHandlerHandle.close();
+ final T proxy = createProxy(interfaceType, client);
+ ok = true;
+ return proxy;
+ } finally {
+ if (! ok) {
+ IoUtils.safeClose(client);
+ }
+ }
+ } finally {
+ IoUtils.safeClose(requestHandlerHandle);
+ }
+ }
+
+ @SuppressWarnings({ "unchecked" })
+ private static <T> T createProxy(final Class<T> interfaceType, final Client<TransporterInvocation, Object> client) {
+ return (T) Proxy.newProxyInstance(interfaceType.getClassLoader(), new Class<?>[] { interfaceType }, new TransporterInvocationHandler(client));
+ }
+}
Added: remoting3/trunk/transporter/src/main/java/org/jboss/remoting/transporter/TransporterInvocation.java
===================================================================
--- remoting3/trunk/transporter/src/main/java/org/jboss/remoting/transporter/TransporterInvocation.java (rev 0)
+++ remoting3/trunk/transporter/src/main/java/org/jboss/remoting/transporter/TransporterInvocation.java 2008-10-22 23:47:56 UTC (rev 4608)
@@ -0,0 +1,93 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2008, JBoss Inc., and individual contributors as indicated
+ * by the @authors tag. See the copyright.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+
+package org.jboss.remoting.transporter;
+
+import java.io.Externalizable;
+import java.io.ObjectOutput;
+import java.io.IOException;
+import java.io.ObjectInput;
+
+/**
+ *
+ */
+public final class TransporterInvocation implements Externalizable {
+
+ private static final long serialVersionUID = -1643169469978213945L;
+ private String name;
+ private Class<?>[] parameterTypes;
+ private Object[] args;
+
+ public TransporterInvocation() {
+ }
+
+ public TransporterInvocation(final String name, final Class<?>[] parameterTypes, final Object[] args) {
+ if (parameterTypes.length != args.length) {
+ throw new IllegalArgumentException("parameter type array length differs from arg array length");
+ }
+ this.name = name;
+ this.parameterTypes = parameterTypes;
+ this.args = args;
+ }
+
+ public void writeExternal(final ObjectOutput out) throws IOException {
+ out.writeObject(name);
+ final Class<?>[] parameterTypes = this.parameterTypes;
+ final Object[] args = this.args;
+ final int len = parameterTypes.length;
+ if (len != args.length) {
+ throw new IllegalStateException("parameter types and/or args length changed");
+ }
+ out.writeShort(len);
+ for (Class<?> type : parameterTypes) {
+ out.writeObject(type);
+ }
+ for (Object arg : args) {
+ out.writeObject(arg);
+ }
+ }
+
+ public void readExternal(final ObjectInput in) throws IOException, ClassNotFoundException {
+ name = (String) in.readObject();
+ final short cnt = in.readShort();
+ final Class<?>[] parameterTypes = new Class<?>[cnt];
+ for (short i = 0; i < cnt; i ++) {
+ parameterTypes[i] = (Class<?>) in.readObject();
+ }
+ final Object[] args = new Object[cnt];
+ for (short i = 0; i < cnt; i ++) {
+ args[i] = in.readObject();
+ }
+ }
+
+ public String getName() {
+ return name;
+ }
+
+ public Class<?>[] getParameterTypes() {
+ return parameterTypes;
+ }
+
+ public Object[] getArgs() {
+ return args;
+ }
+}
Added: remoting3/trunk/transporter/src/main/java/org/jboss/remoting/transporter/TransporterInvocationHandler.java
===================================================================
--- remoting3/trunk/transporter/src/main/java/org/jboss/remoting/transporter/TransporterInvocationHandler.java (rev 0)
+++ remoting3/trunk/transporter/src/main/java/org/jboss/remoting/transporter/TransporterInvocationHandler.java 2008-10-22 23:47:56 UTC (rev 4608)
@@ -0,0 +1,50 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2008, JBoss Inc., and individual contributors as indicated
+ * by the @authors tag. See the copyright.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+
+package org.jboss.remoting.transporter;
+
+import java.lang.reflect.InvocationHandler;
+import java.lang.reflect.Method;
+import java.io.IOException;
+import org.jboss.remoting.Client;
+import org.jboss.remoting.RemoteExecutionException;
+
+/**
+ *
+ */
+public final class TransporterInvocationHandler implements InvocationHandler {
+ private final Client<TransporterInvocation, Object> client;
+
+ public TransporterInvocationHandler(final Client<TransporterInvocation, Object> client) {
+ this.client = client;
+ }
+
+ public Object invoke(final Object proxy, final Method method, final Object[] args) throws Throwable {
+ try {
+ return client.invoke(new TransporterInvocation(method.getName(), method.getParameterTypes(), args));
+ } catch (RemoteExecutionException e) {
+ throw e.getCause();
+ } catch (IOException e) {
+ throw new IllegalStateException("Method invocation failed", e);
+ }
+ }
+}
Added: remoting3/trunk/transporter/src/main/java/org/jboss/remoting/transporter/TransporterRequestListener.java
===================================================================
--- remoting3/trunk/transporter/src/main/java/org/jboss/remoting/transporter/TransporterRequestListener.java (rev 0)
+++ remoting3/trunk/transporter/src/main/java/org/jboss/remoting/transporter/TransporterRequestListener.java 2008-10-22 23:47:56 UTC (rev 4608)
@@ -0,0 +1,62 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2008, JBoss Inc., and individual contributors as indicated
+ * by the @authors tag. See the copyright.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+
+package org.jboss.remoting.transporter;
+
+import org.jboss.remoting.RequestContext;
+import org.jboss.remoting.RemoteExecutionException;
+import org.jboss.remoting.AbstractRequestListener;
+import java.lang.reflect.Method;
+import java.lang.reflect.InvocationTargetException;
+import java.io.IOException;
+
+/**
+ *
+ */
+public final class TransporterRequestListener<T> extends AbstractRequestListener<TransporterInvocation,Object> {
+ private final T target;
+
+ public TransporterRequestListener(final T target) {
+ this.target = target;
+ }
+
+ public void handleRequest(final RequestContext<Object> context, final TransporterInvocation request) throws RemoteExecutionException {
+ try {
+ final Method method = target.getClass().getMethod(request.getName(), request.getParameterTypes());
+ method.invoke(target, request.getArgs());
+ } catch (NoSuchMethodException e) {
+ doSendFailure(context, new NoSuchMethodError("No such method on the remote side: " + e.getMessage()));
+ } catch (InvocationTargetException e) {
+ doSendFailure(context, e.getCause());
+ } catch (IllegalAccessException e) {
+ doSendFailure(context, new IllegalAccessError("Illegal access in remote method invocation: " + e.getMessage()));
+ }
+ }
+
+ private void doSendFailure(final RequestContext<Object> context, final Throwable throwable) {
+ try {
+ context.sendFailure(null, throwable);
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+}
Added: remoting3/trunk/transporter/src/main/java/org/jboss/remoting/transporter/package-info.java
===================================================================
--- remoting3/trunk/transporter/src/main/java/org/jboss/remoting/transporter/package-info.java (rev 0)
+++ remoting3/trunk/transporter/src/main/java/org/jboss/remoting/transporter/package-info.java 2008-10-22 23:47:56 UTC (rev 4608)
@@ -0,0 +1,26 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2008, JBoss Inc., and individual contributors as indicated
+ * by the @authors tag. See the copyright.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+/**
+ * Transporters provide a simple mechanism to access objects remotely. Transporters use Java reflection proxies to
+ * transparently forward method invocations on an interface to the remote server.
+ */
+package org.jboss.remoting.transporter;
More information about the jboss-remoting-commits
mailing list