Package javax.jms

Examples of javax.jms.Session.recover()

306
307
308
309
310
311
312
313
314
315
316
        assertNotNull(msg);       
        assertFalse("Message should not be redelivered.", msg.getJMSRedelivered());
        // Don't ack the message.
       
        // Reset the session.  This should cause the Unacked message to be redelivered.
        session.recover();
               
        // Attempt to Consume the message...
        msg = consumer.receive(2000);
        assertNotNull(msg);       
        assertTrue("Message should be redelivered.", msg.getJMSRedelivered());
View Full Code Here
139
140
141
142
143
144
145
146
147
148
149
      TextMessage tm = (TextMessage)c.receive(1000);

      assertEquals("xoxo", tm.getText());
      assertEquals(1, tm.getIntProperty("JMSXDeliveryCount"));

      s.recover();

      tm = (TextMessage)c.receive(1000);

      assertEquals("xoxo", tm.getText());
      assertEquals(2, tm.getIntProperty("JMSXDeliveryCount"));
View Full Code Here
187
188
189
190
191
192
193
194
195
196
197
            TextMessage tm = (TextMessage)cons.receive(3000);
            assertNotNull(tm);
            assertEquals("testing" + i, tm.getText());
            assertEquals(j + 1, tm.getIntProperty("JMSXDeliveryCount"));
         }
         sess2.recover();
      }
     
      conn.close();
     
     
View Full Code Here
361
362
363
364
365
366
367
368
369
370
371
        
         assertEquals(1, rm.getIntProperty("JMSXDeliveryCount"));
        
         assertFalse(rm.getJMSRedelivered());
        
         consumerSess.recover();
        
         rm = (TextMessage)consumer.receive(1000);
        
         assertNotNull(rm);
        
View Full Code Here
373
374
375
376
377
378
379
380
381
382
383
        
         assertEquals(2, rm.getIntProperty("JMSXDeliveryCount"));
        
         assertTrue(rm.getJMSRedelivered());
        
         consumerSess.recover();
        
         rm = (TextMessage)consumer.receive(1000);
        
         assertNotNull(rm);
        
View Full Code Here
272
273
274
275
276
277
278
279
280
281
282
     
      assertEquals(((MessageProxy)m).getMessage().getMessageID(), ref.getMessage().getMessageID());
     
      ref.releaseMemoryReference();
     
      sess.recover();
     
      TextMessage m3 = (TextMessage)cons.receive();
     
      assertNotNull(m3);
      assertEquals(m.getText(), m3.getText());
View Full Code Here
413
414
415
416
417
418
419
420
421
422
423
      TextMessage m4 = (TextMessage)cons.receive();
     
      assertNotNull(m4);
      assertEquals(m1.getText(), m4.getText());
     
      sess.recover();
     
      TextMessage m5 = (TextMessage)cons.receive();
     
      assertNotNull(m5);
      assertEquals(m1.getText(), m5.getText());
View Full Code Here
837
838
839
840
841
842
843
844
845
846
847
       
        session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
        consumer = session.createConsumer(queue1);
        assertNotNull(consumer.receive(100));
        assertNull(consumer.receive(100));
        session.recover();
       
        long redeliveryDelay = engine.getSetup().getRedeliveryDelay();
         if (redeliveryDelay > 0)
           msg = consumer.receive(redeliveryDelay+100);
         else
View Full Code Here
899
900
901
902
903
904
905
906
907
908
909
        connection.start();
        listenerLock.acquire(1000);
        Thread.sleep(200);
        assertEquals(2,counter);
        consumer.close();
        session.recover();
       
        // Late listener
        session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
        consumer = session.createConsumer(queue1);
        counter = 0;
View Full Code Here
141
142
143
144
145
146
147
148
149
150
151
        MessageListener listener = new MessageListener() {
            @Override
            public void onMessage(Message message) {
                latch.countDown();
                try {
                    session.recover();
                } catch (Exception ignored) {
                    ignored.printStackTrace();
                }

            }
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.