User: pkendall
Date: 01/08/08 17:27:38
Modified: src/main/org/jbossmq/il/rmi RMIServerIL.java
RMIServerILRemote.java
Log:
Major updates (especially to topics).
Speed improvements.
Make JVM IL work (by using a singleton JMSServer).
Message Listeners re-implemented using client-side thread.
Revision Changes Path
1.3 +9 -8 jbossmq/src/main/org/jbossmq/il/rmi/RMIServerIL.java
Index: RMIServerIL.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jbossmq/il/rmi/RMIServerIL.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- RMIServerIL.java 2001/07/16 02:51:46 1.2
+++ RMIServerIL.java 2001/08/09 00:27:38 1.3
@@ -20,14 +20,15 @@
import org.jbossmq.ConnectionToken;
import org.jbossmq.il.ServerIL;
import org.jbossmq.server.JMSServer;
+import org.jbossmq.DurableSubcriptionID;
/**
* The JVM implementation of the ServerIL object
- *
+ *
* @author Hiram Chirino ([EMAIL PROTECTED])
* @author Norbert Lataille ([EMAIL PROTECTED])
- *
- * @version $Revision: 1.2 $
+ *
+ * @version $Revision: 1.3 $
*/
public class RMIServerIL extends java.rmi.server.UnicastRemoteObject implements
RMIServerILRemote {
@@ -45,7 +46,7 @@
public ServerIL cloneServerIL() {
return this;
}
-
+
public void setConnectionToken(ConnectionToken newConnectionToken) {
// We cannot try to cache the token since this IL is stateless
}
@@ -94,10 +95,6 @@
return server.browse(dc, dest, selector);
}
- public void listenerChange(ConnectionToken dc, int subscriberId, boolean
state) throws Exception {
- server.listenerChange(dc, subscriberId, state);
- }
-
public SpyMessage receive(ConnectionToken dc, int subscriberId, long wait)
throws Exception {
return server.receive(dc, subscriberId, wait);
}
@@ -108,6 +105,10 @@
public void unsubscribe(ConnectionToken dc, int subscriptionId) throws
Exception {
server.unsubscribe(dc, subscriptionId);
+ }
+
+ public void destroySubscription(DurableSubcriptionID id) throws Exception {
+ server.destroySubscription(id);
}
public String checkUser(String userName, String password) throws JMSException {
1.3 +24 -24 jbossmq/src/main/org/jbossmq/il/rmi/RMIServerILRemote.java
Index: RMIServerILRemote.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jbossmq/il/rmi/RMIServerILRemote.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- RMIServerILRemote.java 2001/07/16 02:51:46 1.2
+++ RMIServerILRemote.java 2001/08/09 00:27:38 1.3
@@ -23,34 +23,34 @@
/**
* The JVM implementation of the ServerIL object
- *
+ *
* @author Hiram Chirino ([EMAIL PROTECTED])
* @author Norbert Lataille ([EMAIL PROTECTED])
- *
- * @version $Revision: 1.2 $
+ *
+ * @version $Revision: 1.3 $
*/
public interface RMIServerILRemote extends ServerIL, java.rmi.Remote {
- public ServerIL cloneServerIL() throws Exception;
- public void setConnectionToken(ConnectionToken newConnectionToken) throws
Exception;
-
- public String getID() throws Exception;
- public void addMessage(ConnectionToken dc, SpyMessage val) throws Exception;
- public Topic createTopic(ConnectionToken dc, String dest) throws Exception;
- public Queue createQueue(ConnectionToken dc, String dest) throws Exception;
- public void deleteTemporaryDestination(ConnectionToken dc, SpyDestination
dest) throws Exception;
- public void checkID(String ID) throws Exception;
- public void connectionClosing(ConnectionToken dc) throws Exception;
- public TemporaryQueue getTemporaryQueue(ConnectionToken dc) throws Exception;
- public TemporaryTopic getTemporaryTopic(ConnectionToken dc) throws Exception;
- public void acknowledge(ConnectionToken dc, AcknowledgementRequest item)
throws Exception;
- public SpyMessage[] browse(ConnectionToken dc, Destination dest, String
selector) throws Exception;
- public void listenerChange(ConnectionToken dc, int subscriberId, boolean
state) throws Exception;
- public SpyMessage receive(ConnectionToken dc, int subscriberId, long wait)
throws Exception;
- public void setEnabled(ConnectionToken dc, boolean enabled) throws Exception;
- public void unsubscribe(ConnectionToken dc, int subscriptionId) throws
Exception;
- public String checkUser(String userName, String password) throws Exception;
- public void subscribe(ConnectionToken dc, org.jbossmq.Subscription s) throws
Exception;
- public void transact(org.jbossmq.ConnectionToken dc, TransactionRequest t)
throws Exception;
+// public ServerIL cloneServerIL() throws Exception;
+// public void setConnectionToken(ConnectionToken newConnectionToken) throws
Exception;
+//
+// public String getID() throws Exception;
+// public void addMessage(ConnectionToken dc, SpyMessage val) throws Exception;
+// public Topic createTopic(ConnectionToken dc, String dest) throws Exception;
+// public Queue createQueue(ConnectionToken dc, String dest) throws Exception;
+// public void deleteTemporaryDestination(ConnectionToken dc, SpyDestination
dest) throws Exception;
+// public void checkID(String ID) throws Exception;
+// public void connectionClosing(ConnectionToken dc) throws Exception;
+// public TemporaryQueue getTemporaryQueue(ConnectionToken dc) throws Exception;
+// public TemporaryTopic getTemporaryTopic(ConnectionToken dc) throws Exception;
+// public void acknowledge(ConnectionToken dc, AcknowledgementRequest item)
throws Exception;
+// public SpyMessage[] browse(ConnectionToken dc, Destination dest, String
selector) throws Exception;
+// public void listenerChange(ConnectionToken dc, int subscriberId, boolean
state) throws Exception;
+// public SpyMessage receive(ConnectionToken dc, int subscriberId, long wait)
throws Exception;
+// public void setEnabled(ConnectionToken dc, boolean enabled) throws Exception;
+// public void unsubscribe(ConnectionToken dc, int subscriptionId) throws
Exception;
+// public String checkUser(String userName, String password) throws Exception;
+// public void subscribe(ConnectionToken dc, org.jbossmq.Subscription s) throws
Exception;
+// public void transact(org.jbossmq.ConnectionToken dc, TransactionRequest t)
throws Exception;
}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
