User: hiram
Date: 00/11/16 14:43:31
Modified: examples TestClient.java
Log:
These class provide a way to multiplex the use of a socket
Revision Changes Path
1.41 +14 -7 spyderMQ/examples/TestClient.java
Index: TestClient.java
===================================================================
RCS file: /products/cvs/ejboss/spyderMQ/examples/TestClient.java,v
retrieving revision 1.40
retrieving revision 1.41
diff -u -r1.40 -r1.41
--- TestClient.java 2000/07/07 22:37:21 1.40
+++ TestClient.java 2000/11/16 22:43:31 1.41
@@ -68,13 +68,14 @@
static TopicSession sessionTopic;
static QueueSender publisherQueue;
static QueueSession sessionQueue;
+ static InitialContext initialContext;
//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("pubq")) {
- Queue dest = (Queue)new
InitialContext().lookup("queue/"+(String)objects[0]);
+ Queue dest =
(Queue)initialContext.lookup("queue/"+(String)objects[0]);
TextMessage content=sessionQueue.createTextMessage();
content.setText((String)objects[1]);
publisherQueue.send(dest,content);
@@ -82,7 +83,7 @@
}
if (str.equals("pub")) {
- Topic dest = (Topic)new
InitialContext().lookup("topic/"+(String)objects[0]);
+ Topic dest =
(Topic)initialContext.lookup("topic/"+(String)objects[0]);
TextMessage content=sessionTopic.createTextMessage();
content.setText((String)objects[1]);
publisherTopic.publish(dest,content);
@@ -90,7 +91,7 @@
}
if (str.equals("pub2")) {
- Topic dest = (Topic)new
InitialContext().lookup("topic/"+(String)objects[0]);
+ Topic dest =
(Topic)initialContext.lookup("topic/"+(String)objects[0]);
BytesMessage bytesmsg1 = sessionTopic.createBytesMessage();
byte[] data = new byte[100*1024];
bytesmsg1.writeBytes (data, 0 , 10*1024);
@@ -110,14 +111,14 @@
}
if (str.equals("subq")) {
- Queue dest = (Queue)new
InitialContext().lookup("queue/"+(String)objects[0]);
+ Queue dest =
(Queue)initialContext.lookup("queue/"+(String)objects[0]);
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]);
+ Topic dest =
(Topic)initialContext.lookup("topic/"+(String)objects[0]);
TopicSubscriber sub=sessionTopic.createSubscriber(dest);
prop.put(where,sub);
return true;
@@ -272,7 +273,13 @@
prop=new Properties();
- TopicConnectionFactory factoryTopic = (TopicConnectionFactory)new
InitialContext().lookup("TopicConnectionFactory");
+ java.util.Hashtable h = new java.util.Hashtable();
+ h.put(Context.INITIAL_CONTEXT_FACTORY,
"org.jnp.interfaces.NamingContextFactory");
+ h.put(Context.PROVIDER_URL, "127.0.0.1:1099");
+ h.put(Context.URL_PKG_PREFIXES, "org.jnp.interfaces");
+ initialContext = new InitialContext(h);
+
+ TopicConnectionFactory factoryTopic =
(TopicConnectionFactory)initialContext.lookup("TopicConnectionFactory");
TopicConnection connectionTopic =
factoryTopic.createTopicConnection("sahra","spot");
sessionTopic =
connectionTopic.createTopicSession(false,Session.AUTO_ACKNOWLEDGE);
publisherTopic = sessionTopic.createPublisher(null);
@@ -281,7 +288,7 @@
prop.put("ct",connectionTopic);
prop.put("st",sessionTopic);
- QueueConnectionFactory factoryQueue = (QueueConnectionFactory)new
InitialContext().lookup("QueueConnectionFactory");
+ QueueConnectionFactory factoryQueue =
(QueueConnectionFactory)initialContext.lookup("QueueConnectionFactory");
QueueConnection connectionQueue =
factoryQueue.createQueueConnection("sahra","spot");
sessionQueue =
connectionQueue.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
publisherQueue = sessionQueue.createSender(null);
