Package javax.jms

Examples of javax.jms.Session.recover()

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
489
490
491
492
493
494
495
496
497
498
499
         if (_log.isTraceEnabled())
         {
            _log.trace("Recover session " + this);
         }

         session.recover();
      }
      finally
      {
         unlock();
      }
View Full Code Here
145
146
147
148
149
150
151
152
153
154
155
        message = (TextMessage)consumer.receive(1000);
        assertEquals("Second", message.getText());
        assertFalse(message.getJMSRedelivered());

        session.recover();

        message = (TextMessage)consumer.receive(2000);
        assertEquals("Second", message.getText());
        assertTrue(message.getJMSRedelivered());
View Full Code Here
190
191
192
193
194
195
196
197
198
199
200
                        break;
                    case 2:
                        assertEquals("Second", message.getText());
                        assertFalse(message.getJMSRedelivered());
                        session.recover();
                        break;

                    case 3:
                        assertEquals("Second", message.getText());
                        assertTrue(message.getJMSRedelivered());
View Full Code Here
259
260
261
262
263
264
265
266
267
268
269
                    case 2:
                        // This should rollback the delivery of this message..
                        // and re-deliver.
                        assertEquals("Second", message.getText());
                        assertFalse(message.getJMSRedelivered());
                        session.recover();
                        break;

                    case 3:
                        assertEquals("Second", message.getText());
                        assertTrue(message.getJMSRedelivered());
View Full Code Here
63
64
65
66
67
68
69
70
71
72
73
                        if (message.getJMSRedelivered()) {
                            LOG.info("It's a redelivery.");
                            redelivery.countDown();
                        }
                        LOG.info("calling recover() on the session to force redelivery.");
                        session.recover();
                    } catch (JMSException e) {
                        e.printStackTrace();
                    }
                }
            });
View Full Code Here
125
126
127
128
129
130
131
132
133
134
135
        MessageListener listener = new MessageListener() {
            @Override
            public void onMessage(Message message) {
                latch.countDown();
                try {
                    session.recover();
                } catch (Exception ignored) {
                    ignored.printStackTrace();
                }

            }
View Full Code Here
167
168
169
170
171
172
173
174
175
176
177
        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
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.