Package javax.jms

Examples of javax.jms.TopicPublisher.send()

259
260
261
262
263
264
265
266
267
268
269
        TemporaryTopic topic = session.createTemporaryTopic();
        assertNotNull(topic);
        TopicPublisher producer = session.createPublisher(topic);
        MessageConsumer consumer = session.createConsumer(topic);
        conn.start();
        producer.send(session.createTextMessage("hello"));
        session.commit();
        TextMessage tm = (TextMessage) consumer.receive(2000);
        assertNotNull(tm);
        assertEquals("hello", tm.getText());
        session.commit();
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
         ObjectMessage om3 = s.createObjectMessage();
         om3.setObject(to3);

         // send to topic
         publisher.send(om1);

         publisher.send(om2);

         publisher.send(om3);
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
         om3.setObject(to3);

         // send to topic
         publisher.send(om1);

         publisher.send(om2);

         publisher.send(om3);

         ObjectMessage rm1 = (ObjectMessage)sub.receive(HornetQServerTestCase.MAX_TIMEOUT);
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
         // send to topic
         publisher.send(om1);

         publisher.send(om2);

         publisher.send(om3);

         ObjectMessage rm1 = (ObjectMessage)sub.receive(HornetQServerTestCase.MAX_TIMEOUT);

         ObjectMessage rm2 = (ObjectMessage)sub.receive(HornetQServerTestCase.MAX_TIMEOUT);
View Full Code Here
55
56
57
58
59
60
61
62
63
64
65
            Map<Type, TopicPublisher> m = this.producerMap.get(e.getTarget());
            if (m != null) {
                TopicPublisher tp = m.get(e.getType());
                if (tp != null) {
                    log.debug("Sending event to tp");
                    tp.send(session.createTextMessage(this.apply(e)));
                }
                else {
                    log.warn("TopicPublisher is NULL!");
                }
            }
View Full Code Here
92
93
94
95
96
97
98
99
100
101
102
         om1.setObject(to1);
        
    
        
         //send to topic
         publisher.send(om1);
        
    
        
         ObjectMessage rm1 = (ObjectMessage)sub.receive(MAX_TIMEOUT);
        
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
        
         ObjectMessage om3 = s.createObjectMessage();
         om3.setObject(to3);
        
         //send to topic
         publisher.send(om1);
        
         publisher.send(om2);
        
         publisher.send(om3);
        
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
         om3.setObject(to3);
        
         //send to topic
         publisher.send(om1);
        
         publisher.send(om2);
        
         publisher.send(om3);
        
         ObjectMessage rm1 = (ObjectMessage)sub.receive(MAX_TIMEOUT);
        
View Full Code Here
103
104
105
106
107
108
109
110
111
112
113
         //send to topic
         publisher.send(om1);
        
         publisher.send(om2);
        
         publisher.send(om3);
        
         ObjectMessage rm1 = (ObjectMessage)sub.receive(MAX_TIMEOUT);
        
         ObjectMessage rm2 = (ObjectMessage)sub.receive(MAX_TIMEOUT);
        
View Full Code Here
231
232
233
234
235
236
237
238
239
240
241
    try {
      topicConnection = topicConnectionFactory.createTopicConnection();
      topicSession = topicConnection.createTopicSession(transacted, acknowledgeMode);
      topicPublisher = topicSession.createPublisher(topic);
      Message message = createMessage(topicSession);
      topicPublisher.send(message);
      if (transacted) {
        topicSession.commit();
      }

    } finally {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.