User: pkendall
Date: 01/07/30 14:58:38
Modified: src/main/org/jbossmq/il/jvm JVMServerIL.java
Log:
bug fixes for JVM addSubscription (need to clone the Subscription)
Revision Changes Path
1.5 +9 -8 jbossmq/src/main/org/jbossmq/il/jvm/JVMServerIL.java
Index: JVMServerIL.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jbossmq/il/jvm/JVMServerIL.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -u -r1.4 -r1.5
--- JVMServerIL.java 2001/07/29 22:55:08 1.4
+++ JVMServerIL.java 2001/07/30 21:58:37 1.5
@@ -17,17 +17,18 @@
import org.jbossmq.SpyMessage;
import org.jbossmq.AcknowledgementRequest;
import org.jbossmq.SpyDestination;
+import org.jbossmq.Subscription;
import org.jbossmq.ConnectionToken;
import org.jbossmq.il.ServerIL;
import org.jbossmq.server.JMSServer;
/**
* The JVM implementation of the ServerIL object
- *
+ *
* @author Hiram Chirino ([EMAIL PROTECTED])
* @author Norbert Lataille ([EMAIL PROTECTED])
- *
- * @version $Revision: 1.4 $
+ *
+ * @version $Revision: 1.5 $
*/
public class JVMServerIL implements ServerIL {
@@ -39,13 +40,13 @@
}
/**
- * No need to clone because there are no instance variables tha can get
+ * No need to clone because there are no instance variables that can get
* clobbered. All Multiple connections can share the same JVMServerIL object
*/
public ServerIL cloneServerIL() {
return this;
}
-
+
public void setConnectionToken(ConnectionToken newConnectionToken) {
// We cannot try to cache the token since this IL is stateless
}
@@ -114,11 +115,11 @@
return server.checkUser(userName, password);
}
- public void subscribe(ConnectionToken dc, org.jbossmq.Subscription s) throws
Exception {
- server.subscribe(dc, s);
+ public void subscribe(ConnectionToken dc, Subscription s) throws Exception {
+ server.subscribe(dc, s.myClone());
}
- public void transact(org.jbossmq.ConnectionToken dc, TransactionRequest t)
throws JMSException {
+ public void transact(ConnectionToken dc, TransactionRequest t) throws
JMSException {
server.transact(dc, t);
}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
