Package javax.jms

Examples of javax.jms.Session.recover()

281
282
283
284
285
286
287
288
289
290
291
        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
352
353
354
355
356
357
358
359
360
361
362
        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
517
518
519
520
521
522
523
524
525
526
527
                {
                    session.rollback();
                }
                else if (session.getAcknowledgeMode() == Session.CLIENT_ACKNOWLEDGE)
                {
                    session.recover();
                }
            }
        }
        catch (final JMSException jmse)
        {
View Full Code Here
288
289
290
291
292
293
294
295
296
297
298
        //Send 1
        sendAndCommitMessage(producer,"4");

        //Receive 1 and recover
        received = assertReceiveAndValidateMessage(consumer, "4");
        consumerSession.recover();

        //Receive same 1
        received = assertReceiveAndValidateMessage(consumer, "4");
        received.acknowledge();
View Full Code Here
301
302
303
304
305
306
307
308
309
310
311
        sendAndCommitMessage(producer,"6");
        sendAndCommitMessage(producer,"5");

        //Receive 1 of 3 (possibly out of order due to pre-fetch)
        final Message messageBeforeRollback = assertReceiveMessage(consumer);
        consumerSession.recover();

        if (isBroker010())
        {
            //Receive 3 in sorted order (not as per JMS recover)
            received = assertReceiveAndValidateMessage(consumer, "5");
View Full Code Here
426
427
428
429
430
431
432
433
434
435
436
                    else if(_sessionType == Session.CLIENT_ACKNOWLEDGE)
                    {
                         if (_count%10 == 0)
                         {
                             LOGGER.debug("client ack session recover");
                             session.recover();
                         }
                         else
                         {
                             LOGGER.debug("client ack session acknowledge");
                             msg.acknowledge();
View Full Code Here
418
419
420
421
422
423
424
425
426
427
428
         ProxyAssertSupport.assertEquals(1, rm.getIntProperty("JMSXDeliveryCount"));

         ProxyAssertSupport.assertFalse(rm.getJMSRedelivered());

         consumerSess.recover();

         rm = (TextMessage)consumer.receive(1000);

         ProxyAssertSupport.assertNotNull(rm);
View Full Code Here
430
431
432
433
434
435
436
437
438
439
440
         ProxyAssertSupport.assertEquals(2, rm.getIntProperty("JMSXDeliveryCount"));

         ProxyAssertSupport.assertTrue(rm.getJMSRedelivered());

         consumerSess.recover();

         rm = (TextMessage)consumer.receive(1000);

         ProxyAssertSupport.assertNotNull(rm);
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
         ProxyAssertSupport.assertEquals("xoxo", tm.getText());
         ProxyAssertSupport.assertTrue("JMSXDeliveryCount is supposed to exist as a property",
                                       tm.propertyExists("JMSXDeliveryCount"));
         ProxyAssertSupport.assertEquals(1, tm.getIntProperty("JMSXDeliveryCount"));

         s.recover();

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

         ProxyAssertSupport.assertEquals("xoxo", tm.getText());
         ProxyAssertSupport.assertTrue("JMSXDeliveryCount is supposed to exist as a property",
View Full Code Here
224
225
226
227
228
229
230
231
232
233
234
                                             tm.propertyExists("JMSXDeliveryCount"));
               ProxyAssertSupport.assertEquals(j + 1, tm.getIntProperty("JMSXDeliveryCount"));
            }
            if (j != NUM_RECOVERIES - 1)
            {
               sess2.recover();
            }
         }

         tm.acknowledge();
      }
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.