Package javax.jms

Examples of javax.jms.Session.recover()

528
529
530
531
532
533
534
535
536
537
538
                {
                    session.rollback();
                }
                else
                {
                    session.recover();
                }
            }
        }
        catch (final JMSException jmse)
        {
View Full Code Here
193
194
195
196
197
198
199
200
201
202
203
                  assertNotNull(tm);
  
                  assertEquals("Message:" + j, tm.getText());
               }
  
               sess2.recover();
            }
           
            //Prompt them to go to DLQ
            cons.receive(100);
           
View Full Code Here
255
256
257
258
259
260
261
262
263
264
265
                  assertNotNull(tm);
  
                  assertEquals("Message:" + j, tm.getText());
               }
  
               sess2.recover();
            }
           
            cons.receive(100);
           
            //At this point all the messages have been delivered exactly MAX_DELIVERIES times
View Full Code Here
635
636
637
638
639
640
641
642
643
644
645
               assertNotNull(tm);

               assertEquals("Message:" + j, tm.getText());
            }

            sess2.recover();
         }
        
         //At this point all the messages have been delivered exactly MAX_DELIVERIES times - this is ok
         //they haven't exceeded max delivery attempts so shouldn't be in the DLQ - let's check
        
View Full Code Here
192
193
194
195
196
197
198
199
200
201
202
         log.trace("Received " + count + " messages");

         // if ordering group, count should be 1.
         assertEquals(1, count);

         consumerSess.recover();

         assertRemainingMessages(NUM_MSG);

         log.trace("Session recover called");
View Full Code Here
128
129
130
131
132
133
134
135
136
137
138
            for (int i = 0; i < MAX_DELIVERIES; i++)
            {
               TextMessage rm3 = (TextMessage)cons.receive(1000);
               assertNotNull(rm3);
               assertEquals("Message:2", rm3.getText());
               sess2.recover();
            }

            // fourth
            TextMessage rm4 = (TextMessage)cons.receive(1000);
            assertNotNull(rm4);
View Full Code Here
143
144
145
146
147
148
149
150
151
152
153
            for (int i = 0; i < MAX_DELIVERIES; i++)
            {
               TextMessage rm5 = (TextMessage)cons.receive(1000);
               assertNotNull(rm5);
               assertEquals("Message:4", rm5.getText());
               sess2.recover();
            }

            TextMessage rmx = (TextMessage)cons.receive(1000);
            assertNull(rmx);
View Full Code Here
833
834
835
836
837
838
839
840
841
842
843
                  int recoverIdx = rand.nextInt(4);
                  //%25 chance of recover
                  if (recoverIdx == 0)
                  {
                     //redeliver
                     session.recover();
                  }
                  else
                  {
                     //ok
                     synchronized(rcvBuffer1)
View Full Code Here
464
465
466
467
468
469
470
471
472
473
474
         if (HornetQRASession.trace)
         {
            HornetQRASession.log.trace("Recover session " + this);
         }

         session.recover();
      }
      finally
      {
         unlock();
      }
View Full Code Here
126
127
128
129
130
131
132
133
134
135
136
        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.