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

[jBoss CVS Development]

  User: norbert 
  Date: 00/06/18 21:23:11

  Modified:    examples TestClient.java
  Log:
  More work for the OIL
  
  Revision  Changes    Path
  1.39      +10 -1     spyderMQ/examples/TestClient.java
  
  Index: TestClient.java
  ===================================================================
  RCS file: /products/cvs/ejboss/spyderMQ/examples/TestClient.java,v
  retrieving revision 1.38
  retrieving revision 1.39
  diff -u -r1.38 -r1.39
  --- TestClient.java   2000/06/15 23:21:39     1.38
  +++ TestClient.java   2000/06/19 04:23:11     1.39
  @@ -13,7 +13,7 @@
   import javax.jms.TopicSubscriber;
   import javax.jms.QueueReceiver;
   import javax.jms.TopicConnectionFactory;
  -
  +import javax.jms.BytesMessage;
   import javax.jms.QueueConnectionFactory;
   import javax.jms.TopicConnection;
   import javax.jms.QueueConnection;
  @@ -85,6 +85,15 @@
                        TextMessage content=sessionTopic.createTextMessage();
                        content.setText((String)objects[1]);
                        publisherTopic.publish(dest,content);
  +                     return true;
  +             }
  +
  +             if (str.equals("pub2")) {
  +                     Topic dest = (Topic)new 
InitialContext().lookup("topic/"+(String)objects[0]);
  +                     BytesMessage bytesmsg1 = sessionTopic.createBytesMessage();
  +            byte[] data = new byte[100*1024];
  +            bytesmsg1.writeBytes (data, 0 , 10*1024);
  +                     publisherTopic.publish(dest,bytesmsg1);
                        return true;
                }