Package javax.jms

Examples of javax.jms.Session.unsubscribe()

3648
3649
3650
3651
3652
3653
3654
3655
3656
3657
3658
         TextMessage tm = (TextMessage)durable2.receive(1500);
         ProxyAssertSupport.assertNull(tm);

         durable2.close();

         sess2.unsubscribe("mySubscription");

         // Now need to remove the original subscription

         conn1 = JMSTestCase.cf.createConnection();
View Full Code Here
3689
3690
3691
3692
3693
3694
3695
3696
3697
3698
3699
         Session sess1 = conn1.createSession(false, Session.AUTO_ACKNOWLEDGE);

         try
         {
            sess1.unsubscribe("non-existent subscription");
            ProxyAssertSupport.fail();
         }
         catch (JMSException e)
         {
         }
View Full Code Here
114
115
116
117
118
119
120
121
122
123
124
        // 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
145
146
147
148
149
150
151
152
153
154
155
        TopicSubscriber subscriber = sess.createDurableSubscriber(kipper, "kipper");

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

            //Do something to show connection is active.
            sess.rollback();

            fail("Exception was not thrown");
View Full Code Here
391
392
393
394
395
396
397
398
399
400
401
        // 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
554
555
556
557
558
559
560
561
562
563
564
        for(String subscription : _testSubscriptions.keySet())
        {
            Session session = _testSubscriptions.get(subscription);
            try
            {
                session.unsubscribe(subscription);
            }
            catch (JMSException e)
            {
                LOGGER.error("Failed to unsubscribe '" + subscription + "' :" + e.getLocalizedMessage(), e);
                failureCounter++;
View Full Code Here
136
137
138
139
140
141
142
143
144
145
146
            assertEquals(0, subscriptions.length);

            subscriptions = broker.getAdminView().getInactiveDurableTopicSubscribers();
            assertEquals(1, subscriptions.length);

            session.unsubscribe("SubsId");

            Thread.sleep(1000);

            subscriptions = broker.getAdminView().getDurableTopicSubscribers();
            assertEquals(0, subscriptions.length);
View Full Code Here
172
173
174
175
176
177
178
179
180
181
182
        subscriptions = broker.getAdminView().getInactiveDurableTopicSubscribers();
        assertEquals(100, subscriptions.length);

        for (int i = 0; i < 100; i++) {
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            session.unsubscribe("SubsId" + i);
            session.close();
        }

        Thread.sleep(2 * 1000);

 
View Full Code Here
126
127
128
129
130
131
132
133
134
135
136
        Message m = durable.receive(1000);
        assertNull(m);
       
        durable.close();
       
        s.unsubscribe("monicabelucci");
      }
      finally
      {
        if (conn != null)
        {
View Full Code Here
179
180
181
182
183
184
185
186
187
188
189
        Message m = durable.receive(1000);
        assertNull(m);
       
        durable.close();
       
        s.unsubscribe("monicabelucci");
      }
      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.