Package javax.jms

Examples of javax.jms.Session.unsubscribe()

262
263
264
265
266
267
268
269
270
271
272
        // the previous durable subscription is lost and (hopefully) garbage collected.
        assertNull(m);
       
        durable.close();
       
        s.unsubscribe("monicabelucci");
      }
      finally
      {
        if (conn != null)
        {
View Full Code Here
2120
2121
2122
2123
2124
2125
2126
2127
2128
2129
2130
        
         sub1.close();
        
         sub2.close();
        
         sess1.unsubscribe("sub1");
        
         sess1.unsubscribe("sub2");
        
      }
      finally
View Full Code Here
2122
2123
2124
2125
2126
2127
2128
2129
2130
2131
2132
        
         sub2.close();
        
         sess1.unsubscribe("sub1");
        
         sess1.unsubscribe("sub2");
        
      }
      finally
      {
         if (conn1 != null)
View Full Code Here
2390
2391
2392
2393
2394
2395
2396
2397
2398
2399
2400
        
         sub1.close();
        
         sub2.close();
        
         sess1.unsubscribe("sub1");
        
         sess1.unsubscribe("sub2");        

      }
      finally
View Full Code Here
2392
2393
2394
2395
2396
2397
2398
2399
2400
2401
2402
        
         sub2.close();
        
         sess1.unsubscribe("sub1");
        
         sess1.unsubscribe("sub2");        

      }
      finally
      {
         if (conn1 != null)
View Full Code Here
389
390
391
392
393
394
395
396
397
398
399
        tm = (TextMessage)ds.receive(1000);
        assertEquals("two", tm.getText());
       
        ds.close();
       
        s.unsubscribe("monicabelucci");
      }
      finally
      {
        if (conn != null)
        {
View Full Code Here
418
419
420
421
422
423
424
425
426
427
428
        prod.setDeliveryMode(DeliveryMode.PERSISTENT);
 
        prod.send(s.createTextMessage("one"));
 
        cons.close();
        s.unsubscribe("uzzi"); 

        MessageConsumer ds = s.createDurableSubscriber(topic1, "uzzi");
        conn.start();
 
        assertNull(ds.receive(1000));
View Full Code Here
427
428
429
430
431
432
433
434
435
436
437
 
        assertNull(ds.receive(1000));
       
        ds.close();
       
        s.unsubscribe("uzzi");
      }
      finally
      {
        if (conn != null)
        {
View Full Code Here
486
487
488
489
490
491
492
493
494
495
496
 
        TopicSubscriber dursub = s.createDurableSubscriber(topic1, "dursub0");
 
        try
        {
           s.unsubscribe("dursub0");
           fail();
        }
        catch (IllegalStateException e)
        {
           //Ok - it is illegal to ubscribe a subscription if it has active consumers
View Full Code Here
496
497
498
499
500
501
502
503
504
505
506
           //Ok - it is illegal to ubscribe a subscription if it has active consumers
        }
          
        dursub.close();
       
        s.unsubscribe("dursub0");
      }
      finally
      {
        if (conn != null)
        {
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.