[jBoss-Dev] CVS update: spyderMQ/examples TestClient.javaTestServer.java

[jBoss CVS Development]

  User: norbert 
  Date: 00/05/18 13:20:56

  Modified:    examples TestClient.java TestServer.java
  Log:
  second step for queues
  
  Revision  Changes    Path
  1.23      +16 -15    spyderMQ/examples/TestClient.java
  
  Index: TestClient.java
  ===================================================================
  RCS file: /products/cvs/ejboss/spyderMQ/examples/TestClient.java,v
  retrieving revision 1.22
  retrieving revision 1.23
  diff -u -r1.22 -r1.23
  --- TestClient.java   2000/05/18 02:10:03     1.22
  +++ TestClient.java   2000/05/18 20:20:55     1.23
  @@ -5,14 +5,20 @@
    * See terms of license at gnu.org.
    */
   import javax.jms.TopicPublisher;
  +import javax.jms.QueueSender;
   import javax.jms.TopicSession;
  +import javax.jms.QueueSession;
   import javax.jms.TextMessage;
   import javax.jms.MessageConsumer;
   import javax.jms.TopicSubscriber;
  +import javax.jms.QueueReceiver;
   import javax.jms.TopicConnectionFactory;
  +import javax.jms.QueueConnectionFactory;
   import javax.jms.TopicConnection;
  +import javax.jms.QueueConnection;
   import javax.jms.Session;
   import javax.jms.Topic;
  +import javax.jms.Queue;
   
   import java.io.BufferedReader;
   import java.io.InputStreamReader;
  @@ -63,31 +69,20 @@
        static Object obj;
        static TopicPublisher publisher;
        static TopicSession session;
  +     //static QueueSender publisher;
  +     //static QueueSession session;
   
        //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("help")) {
  -                     System.out.println("publish(topicName,text of the msg)");
  -                     System.out.println("newSubscriber=sub(topicName)");
  -                     System.out.println("subscriber.listener()");
  -                     return true;
  -             }
  -             
                if (str.equals("pub")) {
                        Topic dest = (Topic)new 
InitialContext().lookup("topic/"+(String)objects[0]);
  +                     //Queue dest = (Queue)new 
InitialContext().lookup("queue/"+(String)objects[0]);
                        TextMessage content=session.createTextMessage();
                        content.setText((String)objects[1]);
                        publisher.publish(dest,content);
  -                     return true;
  -             }
  -             
  -             if (str.equals("pri")) {
  -                     Topic dest = (Topic)new 
InitialContext().lookup("topic/"+(String)objects[0]);
  -                     TextMessage content=session.createTextMessage();
  -                     content.setText((String)objects[1]);
  -                     
publisher.publish(dest,content,javax.jms.DeliveryMode.NON_PERSISTENT,((Integer)objects[2]).intValue(),0);
  +                     //publisher.send(dest,content);
                        return true;
                }
                
  @@ -100,6 +95,8 @@
                if (str.equals("sub")) {
                        Topic dest = (Topic)new 
InitialContext().lookup("topic/"+(String)objects[0]);
                        TopicSubscriber sub=session.createSubscriber(dest);
  +                     //Queue dest = (Queue)new 
InitialContext().lookup("queue/"+(String)objects[0]);
  +                     //QueueReceiver sub=session.createReceiver(dest);
                        prop.put(where,sub);
                        return true;
                }
  @@ -244,6 +241,10 @@
                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);
                publisher.setTimeToLive(0);
                
                prop=new Properties();
  
  
  
  1.22      +2 -2      spyderMQ/examples/TestServer.java
  
  Index: TestServer.java
  ===================================================================
  RCS file: /products/cvs/ejboss/spyderMQ/examples/TestServer.java,v
  retrieving revision 1.21
  retrieving revision 1.22
  diff -u -r1.21 -r1.22
  --- TestServer.java   2000/05/17 00:31:43     1.21
  +++ TestServer.java   2000/05/18 20:20:55     1.22
  @@ -33,7 +33,7 @@
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    *   @author Rich Johns ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.21 $
  + *   @version $Revision: 1.22 $
    */
   public class TestServer implements Runnable
   {
  @@ -130,7 +130,7 @@
                        queueConnectionFactory = new 
SpyQueueConnectionFactory(distributedQueueConnectionFactory);
   
                        //create the known queues
  -                     subcontext=ctx.createSubcontext("queues");
  +                     subcontext=ctx.createSubcontext("queue");
                        String queues=(String)cfg.get("knownQueues");
                        
                        if (queues!=null) {