Package javax.jms

Examples of javax.jms.Session.createDurableSubscriber()

109
110
111
112
113
114
115
116
117
118
119
      Session s = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
      MessageProducer prod = s.createProducer(topic);
      prod.setDeliveryMode(DeliveryMode.PERSISTENT);

      s.createDurableSubscriber(topic, "monicabelucci");

      ObjectName destObjectName =
         new ObjectName("jboss.messaging.destination:service=Topic,name=Topic");
      List subs = (List)ServerManagement.invoke(destObjectName, "listAllSubscriptions", null, null);
     
View Full Code Here
140
141
142
143
144
145
146
147
148
149
150
      conn = cf.createConnection();
      conn.setClientID("brookeburke");

      s = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);

      MessageConsumer durable = s.createDurableSubscriber(topic, "monicabelucci");

      conn.start();

      TextMessage tm = (TextMessage)durable.receive(1000);
      assertEquals("k", tm.getText());
View Full Code Here
175
176
177
178
179
180
181
182
183
184
185
      Session s = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
      MessageProducer prod = s.createProducer(topic);
      prod.setDeliveryMode(DeliveryMode.PERSISTENT);

      s.createDurableSubscriber(topic, "monicabelucci");

      prod.send(s.createTextMessage("one"));

      conn.close();
View Full Code Here
189
190
191
192
193
194
195
196
197
198
199
      conn = cf.createConnection();

      conn.setClientID("brookeburke");

      s = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
      MessageConsumer durable = s.createDurableSubscriber(topic2, "monicabelucci");

      conn.start();

      Message m = durable.receive(1000);
      assertNull(m);
View Full Code Here
226
227
228
229
230
231
232
233
234
235
236
      prod.setDeliveryMode(DeliveryMode.PERSISTENT);

     
      //fails here
      MessageConsumer durable =
         s.createDurableSubscriber(topic,
                                   "monicabelucci",
                                   "color = 'red' AND shape = 'square'",
                                   false);

      TextMessage tm = s.createTextMessage("A red square message");
View Full Code Here
260
261
262
263
264
265
266
267
268
269
270
      conn.setClientID("brookeburke");

      s = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);

      // modify the selector
      durable = s.createDurableSubscriber(topic,
                                          "monicabelucci",
                                          "color = 'red'",
                                          false);

      conn.start();
View Full Code Here
341
342
343
344
345
346
347
348
349
350
351
      Session s = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
      Topic temporaryTopic = s.createTemporaryTopic();

      try
      {
         s.createDurableSubscriber(temporaryTopic, "mySubscription");
         fail("this should throw exception");
      }
      catch(InvalidDestinationException e)
      {
         // OK
View Full Code Here
381
382
383
384
385
386
387
388
389
390
391
      conn.setClientID("brookeburke");

      Session s = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
      MessageProducer prod = s.createProducer(topic);
      prod.setDeliveryMode(DeliveryMode.PERSISTENT);
      MessageConsumer ds = s.createDurableSubscriber(topic, "monicabelucci");
      conn.start();

      prod.send(s.createTextMessage("one"));
      prod.send(s.createTextMessage("two"));
     
View Full Code Here
411
412
413
414
415
416
417
418
419
420
421
      s = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);

      try
      {
         s.createDurableSubscriber(topic, "monicabelucci");
         fail("should throw exception");
      }
      catch(JMSException e)
      {
         // OK
View Full Code Here
425
426
427
428
429
430
431
432
433
434
435
      log.debug("topic redeployed");

      // since redeployment has an activation semantic, I expect to find the messages there

      topic = (Topic)ic.lookup("/topic/TopicToBeRedeployed");
      ds =  s.createDurableSubscriber(topic, "monicabelucci");
      conn.start();

      tm = (TextMessage)ds.receive(1000);
      assertEquals("two", tm.getText());
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.