User: chirino
Date: 01/08/22 20:57:09
Added: src/main/org/jboss/mq/cluster/jms Tag: Branch_2_4
ClusterConnectionMetaData.java
ClusterTemporaryTopic.java ClusterTopic.java
ClusterTopicConnection.java
ClusterTopicConnectionFactory.java
ClusterTopicPublisher.java ClusterTopicSession.java
ClusterTopicSubscriber.java
Log:
Back porting JBossMQ 1.0.0 BETA 1 to 2_4 branch
Revision Changes Path
No revision
No revision
1.2.2.1 +1 -1
jbossmq/src/main/org/jboss/mq/cluster/jms/ClusterConnectionMetaData.java
Index: ClusterConnectionMetaData.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmq/src/main/org/jboss/mq/cluster/jms/ClusterConnectionMetaData.java,v
retrieving revision 1.2
retrieving revision 1.2.2.1
diff -u -r1.2 -r1.2.2.1
--- ClusterConnectionMetaData.java 2001/08/17 03:04:03 1.2
+++ ClusterConnectionMetaData.java 2001/08/23 03:57:09 1.2.2.1
@@ -17,7 +17,7 @@
*
* @author Hiram Chirino ([EMAIL PROTECTED])
* @created August 16, 2001
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.2.2.1 $
*/
public class ClusterConnectionMetaData implements ConnectionMetaData {
1.2.2.1 +1 -1
jbossmq/src/main/org/jboss/mq/cluster/jms/ClusterTemporaryTopic.java
Index: ClusterTemporaryTopic.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmq/src/main/org/jboss/mq/cluster/jms/ClusterTemporaryTopic.java,v
retrieving revision 1.2
retrieving revision 1.2.2.1
diff -u -r1.2 -r1.2.2.1
--- ClusterTemporaryTopic.java 2001/08/17 03:04:03 1.2
+++ ClusterTemporaryTopic.java 2001/08/23 03:57:09 1.2.2.1
@@ -18,7 +18,7 @@
*
* @author Hiram Chirino ([EMAIL PROTECTED])
* @created August 16, 2001
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.2.2.1 $
*/
public class ClusterTemporaryTopic implements Serializable, TemporaryTopic {
NodeId nodeId;
1.2.2.1 +1 -1 jbossmq/src/main/org/jboss/mq/cluster/jms/ClusterTopic.java
Index: ClusterTopic.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmq/src/main/org/jboss/mq/cluster/jms/ClusterTopic.java,v
retrieving revision 1.2
retrieving revision 1.2.2.1
diff -u -r1.2 -r1.2.2.1
--- ClusterTopic.java 2001/08/17 03:04:03 1.2
+++ ClusterTopic.java 2001/08/23 03:57:09 1.2.2.1
@@ -16,7 +16,7 @@
*
* @author Hiram Chirino ([EMAIL PROTECTED])
* @created August 16, 2001
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.2.2.1 $
*/
public class ClusterTopic implements Serializable, Topic {
1.2.2.1 +1 -1
jbossmq/src/main/org/jboss/mq/cluster/jms/ClusterTopicConnection.java
Index: ClusterTopicConnection.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmq/src/main/org/jboss/mq/cluster/jms/ClusterTopicConnection.java,v
retrieving revision 1.2
retrieving revision 1.2.2.1
diff -u -r1.2 -r1.2.2.1
--- ClusterTopicConnection.java 2001/08/17 03:04:03 1.2
+++ ClusterTopicConnection.java 2001/08/23 03:57:09 1.2.2.1
@@ -42,7 +42,7 @@
*
* @author Hiram Chirino ([EMAIL PROTECTED])
* @created August 16, 2001
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.2.2.1 $
*/
public class ClusterTopicConnection implements Serializable, TopicConnection,
TransportListener {
//Is the connection stopped ?
1.2.2.1 +1 -1
jbossmq/src/main/org/jboss/mq/cluster/jms/ClusterTopicConnectionFactory.java
Index: ClusterTopicConnectionFactory.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmq/src/main/org/jboss/mq/cluster/jms/ClusterTopicConnectionFactory.java,v
retrieving revision 1.2
retrieving revision 1.2.2.1
diff -u -r1.2 -r1.2.2.1
--- ClusterTopicConnectionFactory.java 2001/08/17 03:04:03 1.2
+++ ClusterTopicConnectionFactory.java 2001/08/23 03:57:09 1.2.2.1
@@ -20,7 +20,7 @@
*
* @author Hiram Chirino ([EMAIL PROTECTED])
* @created August 16, 2001
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.2.2.1 $
*/
public class ClusterTopicConnectionFactory implements java.io.Serializable,
javax.jms.TopicConnectionFactory {
1.2.2.1 +1 -1
jbossmq/src/main/org/jboss/mq/cluster/jms/ClusterTopicPublisher.java
Index: ClusterTopicPublisher.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmq/src/main/org/jboss/mq/cluster/jms/ClusterTopicPublisher.java,v
retrieving revision 1.2
retrieving revision 1.2.2.1
diff -u -r1.2 -r1.2.2.1
--- ClusterTopicPublisher.java 2001/08/17 03:04:03 1.2
+++ ClusterTopicPublisher.java 2001/08/23 03:57:09 1.2.2.1
@@ -20,7 +20,7 @@
*
* @author Hiram Chirino ([EMAIL PROTECTED])
* @created August 16, 2001
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.2.2.1 $
*/
public class ClusterTopicPublisher implements TopicPublisher {
1.3.2.1 +2 -3
jbossmq/src/main/org/jboss/mq/cluster/jms/ClusterTopicSession.java
Index: ClusterTopicSession.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmq/src/main/org/jboss/mq/cluster/jms/ClusterTopicSession.java,v
retrieving revision 1.3
retrieving revision 1.3.2.1
diff -u -r1.3 -r1.3.2.1
--- ClusterTopicSession.java 2001/08/21 23:16:18 1.3
+++ ClusterTopicSession.java 2001/08/23 03:57:09 1.3.2.1
@@ -36,17 +36,16 @@
import org.jboss.mq.SpyObjectMessage;
import org.jboss.mq.SpyStreamMessage;
import org.jboss.mq.SpyTextMessage;
+import org.jboss.mq.selectors.Selector;
/**
* This class implements javax.jms.TopicSession
*
* @author Hiram Chirino ([EMAIL PROTECTED])
* @created August 16, 2001
- * @version $Revision: 1.3 $
+ * @version $Revision: 1.3.2.1 $
*/
-public class ClusterTopicSession
- implements TopicSession
-{
+public class ClusterTopicSession implements TopicSession {
//MessageConsumers created by this session
protected HashSet consumers = new HashSet();
1.3.2.1 +5 -4
jbossmq/src/main/org/jboss/mq/cluster/jms/ClusterTopicSubscriber.java
Index: ClusterTopicSubscriber.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmq/src/main/org/jboss/mq/cluster/jms/ClusterTopicSubscriber.java,v
retrieving revision 1.3
retrieving revision 1.3.2.1
diff -u -r1.3 -r1.3.2.1
--- ClusterTopicSubscriber.java 2001/08/21 23:16:18 1.3
+++ ClusterTopicSubscriber.java 2001/08/23 03:57:09 1.3.2.1
@@ -16,16 +16,17 @@
import org.jboss.mq.SpyMessage;
import org.jboss.mq.cluster.transport.NodeId;
+import org.jboss.mq.selectors.Selector;
+
/**
- * This class implements <tt>javax.jms.TopicSubscriber</tt>.
+ * This class implements javax.jms.TopicSubscriber
*
* @author Hiram Chirino ([EMAIL PROTECTED])
* @created August 16, 2001
- * @version $Revision: 1.3 $
+ * @version $Revision: 1.3.2.1 $
*/
-public class ClusterTopicSubscriber
- implements TopicSubscriber
-{
+public class ClusterTopicSubscriber implements TopicSubscriber {
+
// The topic I registered
Topic topic;
//Am I closed ?
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
