Author: mszefler
Date: Thu Jul 27 14:07:02 2006
New Revision: 426239
URL: http://svn.apache.org/viewvc?rev=426239&view=rev
Log:
Added missing RMI transport package.
Added:
incubator/ode/scratch/pxe-iapi/jca-ra/src/main/java/com/fs/pxe/ra/transports/rmi/
incubator/ode/scratch/pxe-iapi/jca-ra/src/main/java/com/fs/pxe/ra/transports/rmi/PxeRemote.java
incubator/ode/scratch/pxe-iapi/jca-ra/src/main/java/com/fs/pxe/ra/transports/rmi/PxeTransportPipeRemote.java
incubator/ode/scratch/pxe-iapi/jca-ra/src/main/java/com/fs/pxe/ra/transports/rmi/RMITransport.java
Added:
incubator/ode/scratch/pxe-iapi/jca-ra/src/main/java/com/fs/pxe/ra/transports/rmi/PxeRemote.java
URL:
http://svn.apache.org/viewvc/incubator/ode/scratch/pxe-iapi/jca-ra/src/main/java/com/fs/pxe/ra/transports/rmi/PxeRemote.java?rev=426239&view=auto
==============================================================================
---
incubator/ode/scratch/pxe-iapi/jca-ra/src/main/java/com/fs/pxe/ra/transports/rmi/PxeRemote.java
(added)
+++
incubator/ode/scratch/pxe-iapi/jca-ra/src/main/java/com/fs/pxe/ra/transports/rmi/PxeRemote.java
Thu Jul 27 14:07:02 2006
@@ -0,0 +1,11 @@
+package com.fs.pxe.ra.transports.rmi;
+
+import java.rmi.Remote;
+import java.rmi.RemoteException;
+
+/**
+ * RMI interface for remote PXE server.
+ */
+public interface PxeRemote extends Remote {
+ public PxeTransportPipeRemote newPipe() throws RemoteException ;
+}
Added:
incubator/ode/scratch/pxe-iapi/jca-ra/src/main/java/com/fs/pxe/ra/transports/rmi/PxeTransportPipeRemote.java
URL:
http://svn.apache.org/viewvc/incubator/ode/scratch/pxe-iapi/jca-ra/src/main/java/com/fs/pxe/ra/transports/rmi/PxeTransportPipeRemote.java?rev=426239&view=auto
==============================================================================
---
incubator/ode/scratch/pxe-iapi/jca-ra/src/main/java/com/fs/pxe/ra/transports/rmi/PxeTransportPipeRemote.java
(added)
+++
incubator/ode/scratch/pxe-iapi/jca-ra/src/main/java/com/fs/pxe/ra/transports/rmi/PxeTransportPipeRemote.java
Thu Jul 27 14:07:02 2006
@@ -0,0 +1,11 @@
+package com.fs.pxe.ra.transports.rmi;
+
+import com.fs.pxe.ra.transports.PxeTransportPipe;
+
+import java.rmi.Remote;
+
+/**
+ * RMI interface for a remote PXE connection listener.
+ */
+public interface PxeTransportPipeRemote extends Remote, PxeTransportPipe {
+}
Added:
incubator/ode/scratch/pxe-iapi/jca-ra/src/main/java/com/fs/pxe/ra/transports/rmi/RMITransport.java
URL:
http://svn.apache.org/viewvc/incubator/ode/scratch/pxe-iapi/jca-ra/src/main/java/com/fs/pxe/ra/transports/rmi/RMITransport.java?rev=426239&view=auto
==============================================================================
---
incubator/ode/scratch/pxe-iapi/jca-ra/src/main/java/com/fs/pxe/ra/transports/rmi/RMITransport.java
(added)
+++
incubator/ode/scratch/pxe-iapi/jca-ra/src/main/java/com/fs/pxe/ra/transports/rmi/RMITransport.java
Thu Jul 27 14:07:02 2006
@@ -0,0 +1,32 @@
+package com.fs.pxe.ra.transports.rmi;
+
+import com.fs.pxe.ra.transports.PxeTransport;
+import com.fs.pxe.ra.transports.PxeTransportPipe;
+
+import java.net.MalformedURLException;
+import java.rmi.Naming;
+import java.rmi.NotBoundException;
+import java.rmi.RemoteException;
+import java.util.Properties;
+
+/**
+ * A very simple RMI-based communication transport.
+ */
+public class RMITransport implements PxeTransport {
+
+ public PxeTransportPipe createPipe(String url, Properties properties) throws
RemoteException {
+ PxeRemote remoteServer;
+ try {
+ remoteServer = (PxeRemote) Naming.lookup(url);
+ } catch (MalformedURLException e) {
+ throw new RemoteException("Invalid URL: " + url, e);
+ } catch (NotBoundException e) {
+ throw new RemoteException("Unable to connect to: " + url, e);
+ } catch (ClassCastException cce) {
+ throw new RemoteException("Protocol error: unexpected remote object
type!", cce);
+ }
+
+ return remoteServer.newPipe();
+ }
+
+}
