User: pkendall
Date: 01/08/08 18:18:27
Modified: src/main/org/jbossmq/il/jvm JVMServerIL.java
JVMServerILFactory.java JVMServerILService.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.6 +8 -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.5
retrieving revision 1.6
diff -u -r1.5 -r1.6
--- JVMServerIL.java 2001/07/30 21:58:37 1.5
+++ JVMServerIL.java 2001/08/09 01:18:27 1.6
@@ -17,8 +17,8 @@
import org.jbossmq.SpyMessage;
import org.jbossmq.AcknowledgementRequest;
import org.jbossmq.SpyDestination;
-import org.jbossmq.Subscription;
import org.jbossmq.ConnectionToken;
+import org.jbossmq.DurableSubcriptionID;
import org.jbossmq.il.ServerIL;
import org.jbossmq.server.JMSServer;
@@ -28,7 +28,7 @@
* @author Hiram Chirino ([EMAIL PROTECTED])
* @author Norbert Lataille ([EMAIL PROTECTED])
*
- * @version $Revision: 1.5 $
+ * @version $Revision: 1.6 $
*/
public class JVMServerIL implements ServerIL {
@@ -40,7 +40,7 @@
}
/**
- * No need to clone because there are no instance variables that can get
+ * No need to clone because there are no instance variables tha can get
* clobbered. All Multiple connections can share the same JVMServerIL object
*/
public ServerIL cloneServerIL() {
@@ -95,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);
}
@@ -111,15 +107,19 @@
server.unsubscribe(dc, subscriptionId);
}
+ public void destroySubscription(DurableSubcriptionID id) throws Exception {
+ server.destroySubscription(id);
+ }
+
public String checkUser(String userName, String password) throws JMSException {
return server.checkUser(userName, password);
}
- public void subscribe(ConnectionToken dc, Subscription s) throws Exception {
+ public void subscribe(ConnectionToken dc, org.jbossmq.Subscription s) throws
Exception {
server.subscribe(dc, s.myClone());
}
- public void transact(ConnectionToken dc, TransactionRequest t) throws
JMSException {
+ public void transact(org.jbossmq.ConnectionToken dc, TransactionRequest t)
throws JMSException {
server.transact(dc, t);
}
1.3 +0 -0 jbossmq/src/main/org/jbossmq/il/jvm/JVMServerILFactory.java
Index: JVMServerILFactory.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmq/src/main/org/jbossmq/il/jvm/JVMServerILFactory.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
1.7 +7 -7 jbossmq/src/main/org/jbossmq/il/jvm/JVMServerILService.java
Index: JVMServerILService.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmq/src/main/org/jbossmq/il/jvm/JVMServerILService.java,v
retrieving revision 1.6
retrieving revision 1.7
diff -u -r1.6 -r1.7
--- JVMServerILService.java 2001/08/09 00:23:56 1.6
+++ JVMServerILService.java 2001/08/09 01:18:27 1.7
@@ -18,14 +18,17 @@
import org.jbossmq.server.JMSServer;
/**
- * Implements the ServerILJMXService which is used to
+ * Implements the ServerILJMXService which is used to
* manage the JVM IL.
*
* @author Hiram Chirino ([EMAIL PROTECTED])
* @author David Maplesden ([EMAIL PROTECTED])
- * @version $Revision: 1.6 $
+ *
+ * @version $Revision: 1.7 $
*/
public class JVMServerILService extends ServerILJMXService implements
JVMServerILServiceMBean {
+
+
/**
* Gives this JMX service a name.
*/
@@ -38,7 +41,7 @@
* @returns ServerIL the instance of this IL
*/
public ServerIL getServerIL() {
- return serverIL;
+ return null;
}
/**
@@ -46,7 +49,6 @@
*/
public void startService() throws Exception {
- serverIL = new JVMServerIL( lookupJMSServer() );
bindJNDIReferences();
}
@@ -87,9 +89,7 @@
// Get an InitialContext
InitialContext ctx = new InitialContext();
org.jboss.naming.NonSerializableFactory.rebind(ctx,
getConnectionFactoryJNDIRef(), scf);
- org.jboss.naming.NonSerializableFactory.rebind(ctx,
getXAConnectionFactoryJNDIRef(), sxacf);
+ org.jboss.naming.NonSerializableFactory.rebind(ctx,
getXAConnectionFactoryJNDIRef(), scf);
}
-
- JVMServerIL serverIL;
}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
