User: norbert
Date: 00/06/15 15:50:30
Modified: src/java/org/spydermq/distributed
ConnectionReceiverFactory.java
Log:
More work on the OIL
Revision Changes Path
1.2 +8 -6
spyderMQ/src/java/org/spydermq/distributed/ConnectionReceiverFactory.java
Index: ConnectionReceiverFactory.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/distributed/ConnectionReceiverFactory.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- ConnectionReceiverFactory.java 2000/05/31 18:10:13 1.1
+++ ConnectionReceiverFactory.java 2000/06/15 22:50:30 1.2
@@ -18,18 +18,20 @@
*
* @author Norbert Lataille ([EMAIL PROTECTED])
*
- * @version $Revision: 1.1 $
+ * @version $Revision: 1.2 $
*/
public class ConnectionReceiverFactory
{
-
+
// Static -------------------------------------------------------
-
- public static ConnectionReceiver createConnectionReceiver(SpyConnection
c,String crClassName) throws Exception
+
+ public static SpyDistributedConnection createDistributedConnection(String
clientID, SpyConnection connection, String crClassName) throws Exception
{
ConnectionReceiver cr =
(ConnectionReceiver)Class.forName(crClassName).newInstance();
- cr.setConnection(c);
- return cr;
+ cr.setConnection(connection);
+ SpyDistributedConnection distributedConnection=new
SpyDistributedConnection(clientID,cr);
+ distributedConnection.setConnectionReceiver(cr.createClient());
+ return distributedConnection;
}
public static void close(SpyDistributedConnection dc) throws Exception
