Package javax.jms

Examples of javax.jms.Session.unsubscribe()

1013
1014
1015
1016
1017
1018
1019
1020
1021
1022
1023
         delta.close();
         epsilon.close();

         sess0.unsubscribe("alpha");
         sess1.unsubscribe("beta");
         sess2.unsubscribe("gamma");
         sess0.unsubscribe("delta");
         sess1.unsubscribe("epsilon");

      }
      finally
View Full Code Here
1076
1077
1078
1079
1080
1081
1082
1083
1084
1085
1086
            sess2.unsubscribe("sub");
         }
         catch (Exception ignore) {}
         try
         {
            sess3.unsubscribe("sub");
         }
         catch (Exception ignore) {}

         MessageConsumer cons1 = sess1.createDurableSubscriber(topic[0], "sub");
View Full Code Here
1218
1219
1220
1221
1222
1223
1224
1225
1226
1227
1228
           //Ok
         }

         try
         {
           sess3.unsubscribe("sub");

           fail("Did not throw InvalidDestinationException");
         }
         catch (InvalidDestinationException e)
         {
View Full Code Here
1350
1351
1352
1353
1354
1355
1356
1357
1358
1359
1360
         sess2.unsubscribe("sub");

         try
         {
           sess3.unsubscribe("sub");
           fail("Should already be unsubscribed");
         }
         catch (InvalidDestinationException e)
         {
           //Ok - the previous unsubscribe should do a cluster wide unsubscribe
View Full Code Here
1771
1772
1773
1774
1775
1776
1777
1778
1779
1780
1781
         assertNull(m);

         cons2.close();

         sess2.unsubscribe("mysub1");
      }
      finally
      {
         if (conn0 != null)
         {
View Full Code Here
494
495
496
497
498
499
500
501
502
503
504
                     ((TextMessage) rMsg).getText());
       
        rMsg = subC.receive(1000);
        assertNull(rMsg);
       
        session.unsubscribe("testResubscribeWithChangedSelectorAndRestart");
       
        subC.close();
        session.close();
        connection.close();
    }
View Full Code Here
142
143
144
145
146
147
148
149
150
151
152
            // create kipper
            Topic kipper = sess.createTopic("kipper");
            TopicSubscriber subscriber = sess.createDurableSubscriber(kipper, "kipper");

            subscriber.close();
            sess.unsubscribe("kipper");

            //Do something to show connection is active.
            sess.rollback();
            conn.close();
        }
View Full Code Here
167
168
169
170
171
172
173
174
175
176
177
            // create kipper
            Topic kipper = sess.createTopic("kipper");
            TopicSubscriber subscriber = sess.createDurableSubscriber(kipper, "kipper");

            subscriber.close();
            sess.unsubscribe("kipper");

            //Do something to show connection is active.
            sess.rollback();
            conn.close();
        }
View Full Code Here
425
426
427
428
429
430
431
432
433
434
435
        assertNull("There should be no more messages for consumption on consumer3.", msg);

        consumer1.close();
        consumer3.close();

        session3.unsubscribe("MySubscription");

        con0.close();
        con1.close();
        con3.close();
    }
View Full Code Here
466
467
468
469
470
471
472
473
474
475
476
      Message msg = liveSubscriber.receive(POSITIVE_RECEIVE_TIMEOUT);
      assertNotNull ("Message should have been received", msg);
      assertEquals ("testDurableWithInvalidSelector2", ((TextMessage) msg).getText());
      assertNull("Should not receive subsequent message", liveSubscriber.receive(200));
        liveSubscriber.close();
        session.unsubscribe("testDurableWithInvalidSelectorSub");
    }
   
    /**
     * This tests the fix for QPID-1085
     * Creates a durable subscriber with an invalid destination, checks that the
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.