User: hiram
Date: 00/11/19 12:00:01
Modified: src/java/org/spydermq/distributed/interfaces
ConnectionReceiverSetup.java
DistributedJMSServer.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.2 +2 -0
spyderMQ/src/java/org/spydermq/distributed/interfaces/ConnectionReceiverSetup.java
Index: ConnectionReceiverSetup.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/distributed/interfaces/ConnectionReceiverSetup.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- ConnectionReceiverSetup.java 2000/06/19 21:51:59 1.1
+++ ConnectionReceiverSetup.java 2000/11/19 20:00:00 1.2
@@ -6,4 +6,6 @@
{
public void setConnection(SpyConnection connection) throws Exception;
public ConnectionReceiver createClient() throws Exception;
+ public void close() throws Exception;
+
}
1.4 +8 -11
spyderMQ/src/java/org/spydermq/distributed/interfaces/DistributedJMSServer.java
Index: DistributedJMSServer.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/distributed/interfaces/DistributedJMSServer.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- DistributedJMSServer.java 2000/06/20 02:19:12 1.3
+++ DistributedJMSServer.java 2000/11/19 20:00:00 1.4
@@ -17,20 +17,14 @@
import org.spydermq.JMSServer;
import org.spydermq.SpyDistributedConnection;
-/**
- * This interface implements callbacks for the JMSServer object
- *
- * @author Norbert Lataille ([EMAIL PROTECTED])
- *
- * @version $Revision: 1.3 $
- */
+import org.spydermq.SpyAcknowledgementItem;
public interface DistributedJMSServer
-{
+{
// Public --------------------------------------------------------
public String getID() throws Exception;
- public void newMessage(SpyMessage val[],String id) throws Exception;
- public void subscribe(Destination dest,SpyDistributedConnection who) throws
Exception;
+ public void newMessage(SpyMessage val[],String id) throws Exception;
+ public void subscribe(Destination dest,SpyDistributedConnection who) throws
Exception;
public void unsubscribe(Destination dest,SpyDistributedConnection who) throws
Exception;
public Topic createTopic(String dest) throws Exception;
public Queue createQueue(String dest) throws Exception;
@@ -39,6 +33,9 @@
public void deleteTemporaryDestination(SpyDestination dest) throws Exception;
public void connectionClosing(SpyDistributedConnection dc) throws Exception;
public void checkID(String ID) throws Exception;
- public SpyMessage queueReceiveNoWait(Queue queue) throws Exception;
public void connectionListening(boolean mode,Destination
dest,SpyDistributedConnection dc) throws Exception;
+ public void acknowledge(SpyAcknowledgementItem[] items, boolean isAck,
SpyDistributedConnection dc) throws Exception;
+ public SpyMessage queueReceive(Queue queue, long wait,SpyDistributedConnection
dc) throws Exception;
+ public void setSpyDistributedConnection(org.spydermq.SpyDistributedConnection
newSpyDistributedConnection) throws Exception;
+
}
