User: chirino
Date: 01/08/22 20:57:08
Modified: src/examples Tag: Branch_2_4 ClusterReceiver.java
ClusterReply.java ClusterRequest.java
ClusterSender.java
Log:
Back porting JBossMQ 1.0.0 BETA 1 to 2_4 branch
Revision Changes Path
No revision
No revision
1.1.2.1 +3 -3 jbossmq/src/examples/ClusterReceiver.java
Index: ClusterReceiver.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/examples/ClusterReceiver.java,v
retrieving revision 1.1
retrieving revision 1.1.2.1
diff -u -r1.1 -r1.1.2.1
--- ClusterReceiver.java 2001/03/02 07:04:47 1.1
+++ ClusterReceiver.java 2001/08/23 03:57:08 1.1.2.1
@@ -10,13 +10,13 @@
/**
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.1 $
+ * @version $Revision: 1.1.2.1 $
*/
public class ClusterReceiver {
public static void main(java.lang.String[] args) throws Exception {
- TopicConnectionFactory connectionFactory = new
org.jbossmq.cluster.jms.ClusterTopicConnectionFactory();
+ TopicConnectionFactory connectionFactory = new
org.jboss.mq.cluster.jms.ClusterTopicConnectionFactory();
TopicConnection connection = connectionFactory.createTopicConnection();
TopicSession session = connection.createTopicSession(false, 0);
Topic topic = session.createTopic("testTopic");
@@ -32,4 +32,4 @@
}
}
-}
\ No newline at end of file
+}
1.1.2.1 +3 -3 jbossmq/src/examples/ClusterReply.java
Index: ClusterReply.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/examples/ClusterReply.java,v
retrieving revision 1.1
retrieving revision 1.1.2.1
diff -u -r1.1 -r1.1.2.1
--- ClusterReply.java 2001/03/02 07:04:47 1.1
+++ ClusterReply.java 2001/08/23 03:57:08 1.1.2.1
@@ -7,7 +7,7 @@
import javax.jms.*;
/**
- * @version $Revision: 1.1 $
+ * @version $Revision: 1.1.2.1 $
*/
public class ClusterReply {
@@ -32,7 +32,7 @@
final String REPLY_TEXT = new String("Here is a reply");
try {
- topicConnectionFactory = new
org.jbossmq.cluster.jms.ClusterTopicConnectionFactory();
+ topicConnectionFactory = new
org.jboss.mq.cluster.jms.ClusterTopicConnectionFactory();
topicConnection =
topicConnectionFactory.createTopicConnection();
topicSession = topicConnection.createTopicSession(false,0);
topic = topicSession.createTopic("testTopic");
@@ -86,4 +86,4 @@
}
}
}
-}
\ No newline at end of file
+}
1.1.2.1 +2 -2 jbossmq/src/examples/ClusterRequest.java
Index: ClusterRequest.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/examples/ClusterRequest.java,v
retrieving revision 1.1
retrieving revision 1.1.2.1
diff -u -r1.1 -r1.1.2.1
--- ClusterRequest.java 2001/03/02 07:04:47 1.1
+++ ClusterRequest.java 2001/08/23 03:57:08 1.1.2.1
@@ -37,7 +37,7 @@
String replyID;
try {
- connectionFactory = new
org.jbossmq.cluster.jms.ClusterTopicConnectionFactory();
+ connectionFactory = new
org.jboss.mq.cluster.jms.ClusterTopicConnectionFactory();
connection = connectionFactory.createTopicConnection();
session = connection.createTopicSession(false, 0);
topic = session.createTopic("testTopic");
@@ -74,4 +74,4 @@
}
}
}
-}
\ No newline at end of file
+}
1.1.2.1 +3 -3 jbossmq/src/examples/ClusterSender.java
Index: ClusterSender.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/examples/ClusterSender.java,v
retrieving revision 1.1
retrieving revision 1.1.2.1
diff -u -r1.1 -r1.1.2.1
--- ClusterSender.java 2001/03/02 07:04:47 1.1
+++ ClusterSender.java 2001/08/23 03:57:08 1.1.2.1
@@ -10,7 +10,7 @@
/**
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.1 $
+ * @version $Revision: 1.1.2.1 $
*/
public class ClusterSender {
@@ -20,7 +20,7 @@
*/
public static void main(java.lang.String[] args) throws Exception {
- TopicConnectionFactory connectionFactory = new
org.jbossmq.cluster.jms.ClusterTopicConnectionFactory();
+ TopicConnectionFactory connectionFactory = new
org.jboss.mq.cluster.jms.ClusterTopicConnectionFactory();
TopicConnection connection = connectionFactory.createTopicConnection();
TopicSession session = connection.createTopicSession(false, 0);
Topic topic = session.createTopic("testTopic");
@@ -38,4 +38,4 @@
connectionFactory.wait();
}
}
-}
\ No newline at end of file
+}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development