User: norbert
Date: 00/06/14 12:16:48
Modified: examples TestClient.java
Log:
Add some JMX instrumentation
change the jnp server
add a mutex object for a better synchronization
Revision Changes Path
1.36 +40 -25 spyderMQ/examples/TestClient.java
Index: TestClient.java
===================================================================
RCS file: /products/cvs/ejboss/spyderMQ/examples/TestClient.java,v
retrieving revision 1.35
retrieving revision 1.36
diff -u -r1.35 -r1.36
--- TestClient.java 2000/06/05 03:32:40 1.35
+++ TestClient.java 2000/06/14 19:16:48 1.36
@@ -63,25 +63,31 @@
static String where;
static int val;
static Object obj;
- //static TopicPublisher publisher;
- //static TopicSession session;
- static QueueSender publisher;
- static QueueSession session;
+ static TopicPublisher publisherTopic;
+ static TopicSession sessionTopic;
+ static QueueSender publisherQueue;
+ static QueueSession sessionQueue;
//if the command is a macro ( obj.macro() or macro() ), expand it
static boolean macro(String str,Object[] objects,Object[] names) throws
Exception
{
- if (str.equals("pub")) {
- //Topic dest = (Topic)new
InitialContext().lookup("topic/"+(String)objects[0]);
+ if (str.equals("pubq")) {
Queue dest = (Queue)new
InitialContext().lookup("queue/"+(String)objects[0]);
- TextMessage content=session.createTextMessage();
+ TextMessage content=sessionQueue.createTextMessage();
content.setText((String)objects[1]);
- //publisher.publish(dest,content);
- publisher.send(dest,content);
+ publisherQueue.send(dest,content);
return true;
}
+ if (str.equals("pub")) {
+ Topic dest = (Topic)new
InitialContext().lookup("topic/"+(String)objects[0]);
+ TextMessage content=sessionTopic.createTextMessage();
+ content.setText((String)objects[1]);
+ publisherTopic.publish(dest,content);
+ return true;
+ }
+
if (str.equals("listen")) {
TestListener listener=new TestListener(val++);
((MessageConsumer)obj).setMessageListener(listener);
@@ -93,15 +99,20 @@
return true;
}
- if (str.equals("sub")) {
- //Topic dest = (Topic)new
InitialContext().lookup("topic/"+(String)objects[0]);
- //TopicSubscriber sub=session.createSubscriber(dest);
+ if (str.equals("subq")) {
Queue dest = (Queue)new
InitialContext().lookup("queue/"+(String)objects[0]);
- QueueReceiver sub=session.createReceiver(dest);
+ QueueReceiver sub=sessionQueue.createReceiver(dest);
prop.put(where,sub);
return true;
}
+ if (str.equals("sub")) {
+ Topic dest = (Topic)new
InitialContext().lookup("topic/"+(String)objects[0]);
+ TopicSubscriber sub=sessionTopic.createSubscriber(dest);
+ prop.put(where,sub);
+ return true;
+ }
+
return false;
}
@@ -249,19 +260,23 @@
BufferedReader d = new BufferedReader(new
InputStreamReader(System.in));
- //TopicConnectionFactory factory = (TopicConnectionFactory)new
InitialContext().lookup("TopicConnectionFactory");
- //TopicConnection connection =
factory.createTopicConnection("sahra","spot");
- //session =
connection.createTopicSession(false,Session.AUTO_ACKNOWLEDGE);
- //publisher = session.createPublisher(null);
- QueueConnectionFactory factory = (QueueConnectionFactory)new
InitialContext().lookup("QueueConnectionFactory");
- QueueConnection connection =
factory.createQueueConnection("sahra","spot");
- session =
connection.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
- publisher = session.createSender(null);
-
prop=new Properties();
- prop.put("c",connection);
- prop.put("s",session);
- prop.put("p",publisher);
+
+ TopicConnectionFactory factoryTopic = (TopicConnectionFactory)new
InitialContext().lookup("TopicConnectionFactory");
+ TopicConnection connectionTopic =
factoryTopic.createTopicConnection("sahra","spot");
+ sessionTopic =
connectionTopic.createTopicSession(false,Session.AUTO_ACKNOWLEDGE);
+ publisherTopic = sessionTopic.createPublisher(null);
+
+ prop.put("ct",connectionTopic);
+ prop.put("st",sessionTopic);
+
+ QueueConnectionFactory factoryQueue = (QueueConnectionFactory)new
InitialContext().lookup("QueueConnectionFactory");
+ QueueConnection connectionQueue =
factoryQueue.createQueueConnection("sahra","spot");
+ sessionQueue =
connectionQueue.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
+ publisherQueue = sessionQueue.createSender(null);
+
+ prop.put("cq",connectionQueue);
+ prop.put("sq",sessionQueue);
while (true) {
