User: hiram
Date: 00/11/19 12:00:00
Modified: src/java/org/spydermq/distributed
ConnectionReceiverFactory.java
Log:
Commiting several changes:
- Removed ConnectionQueue and SessionQueue. All consumer managment is done at the
SpyConnection now.
- Unacknowledged messages are maintained on the server side now.
(JMSServerQueueReceiver)
- Acknowlegment messages are sent to the server from the client.
- Optimized the OIL and UIL transports by caching the DistributedConnection on the
JMSServer when the ConnectionReciver is setup.
- Cleaned up the OIL by only using the Object(Output/Input) streams instead of both
Object(Output/Input) and Buffered(Output/Input) streams.
- A QueueReceiver now does a request for a single message on a receive() method
instead turning on/off listen to get a message.
- For the OIL and UIL, a connection failure/termination is now handled gracefully
(if connectionCLosing() was called, no errors shown, if it was not called and the
connection failed, we call it).
Revision Changes Path
1.7 +10 -12
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.6
retrieving revision 1.7
diff -u -r1.6 -r1.7
--- ConnectionReceiverFactory.java 2000/11/10 20:08:03 1.6
+++ ConnectionReceiverFactory.java 2000/11/19 20:00:00 1.7
@@ -20,7 +20,7 @@
*
* @author Norbert Lataille ([EMAIL PROTECTED])
*
- * @version $Revision: 1.6 $
+ * @version $Revision: 1.7 $
*/
public class ConnectionReceiverFactory
{
@@ -36,15 +36,13 @@
return distributedConnection;
}
- public static void close(SpyDistributedConnection dc) throws Exception
- {
- dc.cr.close();
-
- // HRC: Check to see if the dc.cr really is a Remote object
- // You have this case when using the RMI Receiver classes
- if( dc.cr instanceof Remote ) {
- UnicastRemoteObject.unexportObject((Remote)dc.cr,true);
- }
-
- }
+ public static void close(SpyDistributedConnection dc) throws Exception {
+ dc.cr_server.close();
+
+ // HRC: Check to see if the dc.cr really is a Remote object
+ // You have this case when using the RMI Receiver classes
+ if (dc.cr instanceof Remote) {
+ UnicastRemoteObject.unexportObject((Remote) dc.cr, true);
+ }
+ }
}
