Examples of deliverNow()

Examples of org.hornetq.core.server.impl.QueueImpl.deliverNow()

87
88
89
90
91
92
93
94
95
96
97
      toggler.join();

      consumer.setStatusImmediate(HandleStatus.HANDLED);

      queue.deliverNow();

      if (sender.getException() != null)
      {
         throw sender.getException();
      }
View Full Code Here

Examples of org.hornetq.core.server.impl.QueueImpl.deliverNow()

290
291
292
293
294
295
296
297
298
299
300
      Assert.assertTrue(consumer.getReferences().isEmpty());
      Assert.assertEquals(10, queue.getMessageCount());
      Assert.assertEquals(0, queue.getScheduledCount());

      queue.deliverNow();

      assertRefListsIdenticalRefs(refs, consumer.getReferences());
      Assert.assertEquals(numMessages, queue.getMessageCount());
      Assert.assertEquals(0, queue.getScheduledCount());
      Assert.assertEquals(numMessages, queue.getDeliveringCount());
View Full Code Here

Examples of org.hornetq.core.server.impl.QueueImpl.deliverNow()

335
336
337
338
339
340
341
342
343
344
345
      Assert.assertEquals(10, queue.getMessageCount());
      Assert.assertEquals(0, queue.getScheduledCount());
      Assert.assertEquals(0, queue.getDeliveringCount());

      queue.deliverNow();

      Assert.assertEquals(10, queue.getMessageCount());
      Assert.assertEquals(0, queue.getScheduledCount());
      Assert.assertEquals(0, queue.getDeliveringCount());
      Assert.assertTrue(consumer.getReferences().isEmpty());
View Full Code Here

Examples of org.hornetq.core.server.impl.QueueImpl.deliverNow()

344
345
346
347
348
349
350
351
352
353
354
      Assert.assertEquals(0, queue.getDeliveringCount());
      Assert.assertTrue(consumer.getReferences().isEmpty());

      consumer.setStatusImmediate(HandleStatus.HANDLED);

      queue.deliverNow();

      assertRefListsIdenticalRefs(refs, consumer.getReferences());
      Assert.assertEquals(10, queue.getMessageCount());
      Assert.assertEquals(0, queue.getScheduledCount());
      Assert.assertEquals(10, queue.getDeliveringCount());
View Full Code Here

Examples of org.hornetq.core.server.impl.QueueImpl.deliverNow()

389
390
391
392
393
394
395
396
397
398
399
      Assert.assertEquals(10, queue.getMessageCount());
      Assert.assertEquals(0, queue.getScheduledCount());
      Assert.assertEquals(0, queue.getDeliveringCount());

      queue.deliverNow();

      Assert.assertEquals(10, queue.getMessageCount());
      Assert.assertEquals(0, queue.getScheduledCount());
      Assert.assertEquals(0, queue.getDeliveringCount());
      Assert.assertTrue(consumer.getReferences().isEmpty());
View Full Code Here

Examples of org.hornetq.core.server.impl.QueueImpl.deliverNow()

421
422
423
424
425
426
427
428
429
430
431
         refs.add(ref);

         queue.addTail(ref);
      }

      queue.deliverNow();

      assertRefListsIdenticalRefs(refs, consumer.getReferences());
      Assert.assertEquals(30, queue.getMessageCount());
      Assert.assertEquals(0, queue.getScheduledCount());
      Assert.assertEquals(30, queue.getDeliveringCount());
View Full Code Here

Examples of org.hornetq.core.server.impl.QueueImpl.deliverNow()

482
483
484
485
486
487
488
489
490
491
492
      FakeConsumer consumer = new FakeConsumer();

      queue.addConsumer(consumer);

      queue.deliverNow();

      List<MessageReference> allRefs = new ArrayList<MessageReference>();

      allRefs.addAll(refs2);
      allRefs.addAll(refs1);
View Full Code Here

Examples of org.hornetq.core.server.impl.QueueImpl.deliverNow()

528
529
530
531
532
533
534
535
536
537
538
      FakeConsumer cons1 = new FakeConsumer();

      queue.addConsumer(cons1);

      queue.deliverNow();

      Assert.assertEquals(numMessages, queue.getMessageCount());
      Assert.assertEquals(0, queue.getScheduledCount());
      Assert.assertEquals(numMessages, queue.getDeliveringCount());
View Full Code Here

Examples of org.hornetq.core.server.impl.QueueImpl.deliverNow()

1207
1208
1209
1210
1211
1212
1213
1214
1215
1216
1217
      if (!direct)
      {
         queue.addConsumer(consumer);

         queue.deliverNow();
      }

      Assert.assertEquals(6, queue.getMessageCount());
     
      awaitExecution();;
View Full Code Here

Examples of org.hornetq.core.server.impl.QueueImpl.deliverNow()

1229
1230
1231
1232
1233
1234
1235
1236
1237
1238
1239
      consumer = new FakeConsumer();

      queue.addConsumer(consumer);

      queue.deliverNow();

      Assert.assertEquals(4, queue.getMessageCount());

      Assert.assertEquals(4, consumer.getReferences().size());
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.