Package org.jboss.test.messaging.jms.message

Examples of org.jboss.test.messaging.jms.message.SimpleJMSTextMessage

55
56
57
58
59
60
61
62
63
       super.tearDown();
    }

    protected Message createForeignMessage() throws Exception
    {
        SimpleJMSTextMessage m = new SimpleJMSTextMessage();
        m.setText("this is the payload");
        return m;
    }
View Full Code Here
308
309
310
311
312
313
314
315
316
317
318
         // send a message that is not created by the session

         cconn.start();

         Message m = new SimpleJMSTextMessage("something");
         p.send(m);        

         TextMessage rec = (TextMessage)c.receive(3000);
        
         assertEquals("something", rec.getText());
View Full Code Here
45
46
47
48
49
50
51
52
53
        super(name);
    }

    protected Message createForeignMessage() throws Exception
    {
        SimpleJMSTextMessage m = new SimpleJMSTextMessage();
        m.setText("this is the payload");
        return m;
    }
View Full Code Here
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
      Session s = c.createSession(false, Session.AUTO_ACKNOWLEDGE);

      MessageProducer p = s.createProducer(queue1);

      // create a Bytes foreign message
      SimpleJMSTextMessage txt = new SimpleJMSTextMessage("hello from Brazil!");
      txt.setJMSDestination(null);

      p.send(txt);

      assertNotNull(txt.getJMSDestination());

      MessageConsumer cons = s.createConsumer(queue1);
      c.start();

      TextMessage tm = (TextMessage)cons.receive();
      assertNotNull(tm);
      assertEquals("hello from Brazil!", txt.getText());
    }
    catch(Exception e)
    {
      e.printStackTrace();
    }
View Full Code Here
338
339
340
341
342
343
344
345
346
347
348
         // send a message that is not created by the session

         cconn.start();

         Message m = new SimpleJMSTextMessage("something");
         p.send(m);        

         TextMessage rec = (TextMessage)c.receive(3000);
        
         assertEquals("something", rec.getText());
View Full Code Here
TOP

Related Classes of org.jboss.test.messaging.jms.message.SimpleJMSTextMessage

  • org.jboss.test.messaging.jms.CTSMiscellaneousTest
  • org.jboss.test.messaging.jms.message.foreign.ForeignTextMessageTest
  • org.jboss.test.messaging.jms.MessageProducerTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.