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

[jBoss CVS Development]

  User: norbert 
  Date: 00/05/24 18:18:32

  Modified:    examples TestClient.java
  Log:
  More for P2P :
  Create a new class ( ConnectionQueue ) which holds the subscribers HashSet
  
  Revision  Changes    Path
  1.28      +20 -27    spyderMQ/examples/TestClient.java
  
  Index: TestClient.java
  ===================================================================
  RCS file: /products/cvs/ejboss/spyderMQ/examples/TestClient.java,v
  retrieving revision 1.27
  retrieving revision 1.28
  diff -u -r1.27 -r1.28
  --- TestClient.java   2000/05/24 19:17:17     1.27
  +++ TestClient.java   2000/05/25 01:18:32     1.28
  @@ -62,22 +62,22 @@
        static String where;
        static int val;
        static Object obj;
  -     static TopicPublisher publisher;
  -     static TopicSession session;
  -     //static QueueSender publisher;
  -     //static QueueSession session;
  +     //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("pub")) {
  -                     Topic dest = (Topic)new 
InitialContext().lookup("topic/"+(String)objects[0]);
  -                     //Queue dest = (Queue)new 
InitialContext().lookup("queue/"+(String)objects[0]);
  +                     //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);
  -                     //publisher.send(dest,content);
  +                     //publisher.publish(dest,content);
  +                     publisher.send(dest,content);
                        return true;
                }
                
  @@ -88,21 +88,14 @@
                }
                
                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);
  +                     //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;
                }
                
  -             if (str.equals("sel")) {
  -                     Topic dest = (Topic)new 
InitialContext().lookup("topic/"+(String)objects[0]);                   
  -                     TopicSubscriber 
sub=session.createSubscriber(dest,(String)objects[1],false);
  -                     prop.put(where,sub);
  -                     return true;
  -             }
  -
                return false;
        }
   
  @@ -246,14 +239,14 @@
                
                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);
  +             //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);
                publisher.setTimeToLive(0);
                
                prop=new Properties();