Package javax.jms

Examples of javax.jms.Session.recover()

240
241
242
243
244
245
246
247
248
249
250
        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
311
312
313
314
315
316
317
318
319
320
321
        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
119
120
121
122
123
124
125
126
127
128
129
        MessageListener listener = new MessageListener() {
            public void onMessage(Message message) {
                latch.countDown();
                try {
                    session.recover();
                } catch (Exception ignored) {
                    ignored.printStackTrace();
                }

            }
View Full Code Here
119
120
121
122
123
124
125
126
127
128
129
        MessageListener listener = new MessageListener() {
            public void onMessage(Message message) {
                latch.countDown();
                try {
                    session.recover();
                } catch (Exception ignored) {
                    ignored.printStackTrace();
                }

            }
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
                        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
146
147
148
149
150
151
152
153
154
155
156
       
        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
257
258
259
260
261
262
263
264
265
266
267
                            break;                       
                      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
124
125
126
127
128
129
130
131
132
133
134
        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
235
236
237
238
239
240
241
242
243
244
245
        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
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.