Package javax.jms

Examples of javax.jms.TopicSession.unsubscribe()

116
117
118
119
120
121
122
123
124
125
126
      TopicSession ts = conn.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);

      try
      {
         ts.unsubscribe("invalid-subscription-name");
         fail("this should fail");
      }
      catch(javax.jms.InvalidDestinationException e)
      {
         // OK
View Full Code Here
527
528
529
530
531
532
533
534
535
536
537
    */
   public void removeDurableSubscription() throws Exception
   {

      TopicSession session = topicDurableConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
      session.unsubscribe("test");
   }

   /**
    * The JUnit setup method
    *
 
View Full Code Here
842
843
844
845
846
847
848
849
850
851
852
      sub1.close();
      sub2.close();
      sub3.close();

      session.unsubscribe("sub1");

      topicConnection.stop();
      topicConnection.close();

      disconnect();
View Full Code Here
1064
1065
1066
1067
1068
1069
1070
1071
1072
1073
1074
         getLog().debug("Closing the send session");
         sendSession.close();

         getLog().debug("Removing the subscription");
         subSession = topicConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
         subSession.unsubscribe("test");

      }
      finally
      {
         getLog().debug("Closing the connection");
View Full Code Here
1136
1137
1138
1139
1140
1141
1142
1143
1144
1145
1146
         assertTrue("Should get Message2", message.getText().equals("Message2"));
         getLog().debug("Closing the subscriber");

         getLog().debug("Removing the subscription");
         subSession = topicConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
         subSession.unsubscribe("test");
         subSession.close();

      }
      finally
      {
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
         TopicSession ts = conn.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);

         try
         {
            ts.unsubscribe("invalid-subscription-name");
            ProxyAssertSupport.fail("this should fail");
         }
         catch (javax.jms.InvalidDestinationException e)
         {
            // OK
View Full Code Here
585
586
587
588
589
590
591
592
593
594
595
        
         cons1.close();
        
         cons2.close();    
        
         s.unsubscribe("SubscriberA");
        
         s.unsubscribe("SubscriberB");
        
         conn.close();
        
View Full Code Here
587
588
589
590
591
592
593
594
595
596
597
        
         cons2.close();    
        
         s.unsubscribe("SubscriberA");
        
         s.unsubscribe("SubscriberB");
        
         conn.close();
        
         removeAllMessages("TopicSubscriptionList", false, 0);
        
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
        session1.commit();

        tm = (TextMessage) sub.receive(2000);
        assertNotNull(tm);
        session1.commit();
        session1.unsubscribe("subscription0");

        try
        {
            session1.unsubscribe("not a subscription");
            fail("expected InvalidDestinationException when unsubscribing from unknown subscription");
View Full Code Here
66
67
68
69
70
71
72
73
74
75
76
        session1.commit();
        session1.unsubscribe("subscription0");

        try
        {
            session1.unsubscribe("not a subscription");
            fail("expected InvalidDestinationException when unsubscribing from unknown subscription");
        }
        catch (InvalidDestinationException e)
        {
            ; // PASS
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.