User: hiram
Date: 00/12/11 21:58:49
Modified: src/java/org/spydermq/distributed/interfaces
ConnectionReceiverSetup.java
ConnectionReceiver.java
DistributedJMSServerSetup.java
DistributedJMSServer.java
Added: src/java/org/spydermq/distributed/interfaces
DistributedConnectionFactory.java
Removed: src/java/org/spydermq/distributed/interfaces
DistributedQueueConnectionFactory.java
DistributedTopicConnectionFactory.java
Log:
Several Chanages:
- Invocation layer simplified by joing the DistributedQueueConnectionFactory and
DistributedTopicConnectionFactory into DistributedConnectionFactory
- Seperated server code from client code ( server code moved to org.spydermq.server )
- All publish() calls are now sync to the provider.
- Added a Transaction class to better represent a commit/rollback request to the
server.
- Now have a InvocationLayerFactory so that we can potentialy load multiple
invocation layers (OIL/UIL/RMI) at the same time.
Revision Changes Path
1.3 +0 -2
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.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- ConnectionReceiverSetup.java 2000/11/19 20:00:00 1.2
+++ ConnectionReceiverSetup.java 2000/12/12 05:58:47 1.3
@@ -6,6 +6,4 @@
{
public void setConnection(SpyConnection connection) throws Exception;
public ConnectionReceiver createClient() throws Exception;
- public void close() throws Exception;
-
}
1.5 +5 -5
spyderMQ/src/java/org/spydermq/distributed/interfaces/ConnectionReceiver.java
Index: ConnectionReceiver.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/distributed/interfaces/ConnectionReceiver.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -u -r1.4 -r1.5
--- ConnectionReceiver.java 2000/06/19 21:51:59 1.4
+++ ConnectionReceiver.java 2000/12/12 05:58:48 1.5
@@ -16,7 +16,7 @@
*
* @author Norbert Lataille ([EMAIL PROTECTED])
*
- * @version $Revision: 1.4 $
+ * @version $Revision: 1.5 $
*/
public interface ConnectionReceiver
@@ -24,11 +24,11 @@
// Public --------------------------------------------------------
//A message has arrived for the Connection
- public void receive(SpyDestination dest,SpyMessage mes) throws Exception;
+ public void receive(SpyDestination dest,SpyMessage mes) throws Exception;
//Many messages have arrived for this Connection
- public void receiveMultiple(SpyDestination dest,SpyMessage mes[]) throws
Exception;
+ public void receiveMultiple(SpyDestination dest,SpyMessage mes[]) throws
Exception;
//One TemporaryDestination has been deleted
- public void deleteTemporaryDestination(SpyDestination dest) throws Exception;
+ public void deleteTemporaryDestination(SpyDestination dest) throws Exception;
//The connection is closed
- public void close() throws Exception;
+ public void close() throws Exception;
}
1.2 +7 -1
spyderMQ/src/java/org/spydermq/distributed/interfaces/DistributedJMSServerSetup.java
Index: DistributedJMSServerSetup.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/distributed/interfaces/DistributedJMSServerSetup.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- DistributedJMSServerSetup.java 2000/06/19 04:23:13 1.1
+++ DistributedJMSServerSetup.java 2000/12/12 05:58:48 1.2
@@ -1,6 +1,12 @@
+/*
+ * spyderMQ, the OpenSource JMS implementation
+ *
+ * Distributable under GPL license.
+ * See terms of license at gnu.org.
+ */
package org.spydermq.distributed.interfaces;
-import org.spydermq.JMSServer;
+import org.spydermq.server.JMSServer;
public interface DistributedJMSServerSetup
{
1.5 +15 -13
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.4
retrieving revision 1.5
diff -u -r1.4 -r1.5
--- DistributedJMSServer.java 2000/11/19 20:00:00 1.4
+++ DistributedJMSServer.java 2000/12/12 05:58:49 1.5
@@ -12,30 +12,32 @@
import javax.jms.Queue;
import javax.jms.TemporaryTopic;
import javax.jms.TemporaryQueue;
+
import org.spydermq.SpyMessage;
import org.spydermq.SpyDestination;
-import org.spydermq.JMSServer;
import org.spydermq.SpyDistributedConnection;
-
import org.spydermq.SpyAcknowledgementItem;
+import org.spydermq.Transaction;
+
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 unsubscribe(Destination dest,SpyDistributedConnection who) throws
Exception;
- public Topic createTopic(String dest) throws Exception;
- public Queue createQueue(String dest) throws Exception;
public TemporaryTopic getTemporaryTopic(SpyDistributedConnection dc) throws
Exception;
public TemporaryQueue getTemporaryQueue(SpyDistributedConnection dc) throws
Exception;
- public void deleteTemporaryDestination(SpyDestination dest) throws Exception;
- public void connectionClosing(SpyDistributedConnection dc) throws Exception;
+ public void connectionClosing(SpyDistributedConnection dc) throws Exception;
public void checkID(String ID) 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;
-
+ public void acknowledge(SpyDistributedConnection dc, SpyAcknowledgementItem
item) throws Exception;
+ public void addMessage(SpyDistributedConnection dc, SpyMessage message) throws
Exception;
+ public void connectionListening(SpyDistributedConnection dc, boolean
mode,Destination dest) throws Exception;
+ public Queue createQueue(SpyDistributedConnection dc, String dest) throws
Exception;
+ public Topic createTopic(SpyDistributedConnection dc, String dest) throws
Exception;
+ public void deleteTemporaryDestination(SpyDistributedConnection dc,
SpyDestination dest) throws Exception;
+ public SpyMessage queueReceive(SpyDistributedConnection dc, Queue queue, long
wait) throws Exception;
+ public void subscribe(SpyDistributedConnection dc, Destination dest) throws
Exception;
+ public void transact(SpyDistributedConnection dc, Transaction t) throws
Exception;
+ public void unsubscribe(SpyDistributedConnection dc, Destination dest) throws
Exception;
+
}
1.1
spyderMQ/src/java/org/spydermq/distributed/interfaces/DistributedConnectionFactory.java
Index: DistributedConnectionFactory.java
===================================================================
/*
* spyderMQ, the OpenSource JMS implementation
*
* Distributable under GPL license.
* See terms of license at gnu.org.
*/
package org.spydermq.distributed.interfaces;
import javax.jms.QueueConnection;
import javax.jms.TopicConnection;
import org.spydermq.server.JMSServer;
import org.spydermq.security.SecurityManager;
public interface DistributedConnectionFactory
{
// Public --------------------------------------------------------
public QueueConnection createQueueConnection() throws Exception;
public QueueConnection createQueueConnection(String userName, String password)
throws Exception;
public void setServer(DistributedJMSServer theServer) throws Exception;
public void setSecurityManager(SecurityManager securityManager) throws
Exception;
public TopicConnection createTopicConnection() throws Exception;
public TopicConnection createTopicConnection(String userName, String password)
throws Exception;
public void setConnectionReceiverClassName(String className) throws Exception;
}
