Package org.springframework.amqp.rabbit.core

Examples of org.springframework.amqp.rabbit.core.RabbitTemplate.receiveAndConvert()

343
344
345
346
347
348
349
350
351
352
353
    template.convertAndSend("Hello, Rabbit!");
    template.convertAndSend("Hello, AMQP!");

    int count = 0;
    while (true) {
      String message = (String) template.receiveAndConvert();
      if (message == null) {
        break;
      }
      else {
        count++;
View Full Code Here
94
95
96
97
98
99
100
101
102
103
104
  }

  @Override
  protected void verifyOnDemandQueues(MessageChannel y3, MessageChannel z3) {
    RabbitTemplate template = new RabbitTemplate(rabbitAvailableRule.getResource());
    Object y = template.receiveAndConvert("xdbus.queue:y");
    assertNotNull(y);
    assertEquals("y", y);
    Object z = template.receiveAndConvert("xdbus.queue:z");
    assertNotNull(z);
    assertEquals("z", z);
View Full Code Here
418
419
420
421
422
423
424
425
426
427
428
    RabbitTemplate template = new RabbitTemplate(this.rabbitAvailableRule.getResource());
    template.convertAndSend("", "xdbustest.dlqtest", "foo");

    int n = 0;
    while (n++ < 100) {
      Object deadLetter = template.receiveAndConvert("xdbustest.dlqtest.dlq");
      if (deadLetter != null) {
        assertEquals("foo", deadLetter);
        break;
      }
      Thread.sleep(100);
View Full Code Here
97
98
99
100
101
102
103
104
105
106
107
  protected void verifyOnDemandQueues(MessageChannel y3, MessageChannel z3) {
    RabbitTemplate template = new RabbitTemplate(rabbitAvailableRule.getResource());
    Object y = template.receiveAndConvert("xdbus.queue:y");
    assertNotNull(y);
    assertEquals("y", y);
    Object z = template.receiveAndConvert("xdbus.queue:z");
    assertNotNull(z);
    assertEquals("z", z);
  }

  @Override
View Full Code Here
510
511
512
513
514
515
516
517
518
519
520
      @Override
      public Object receive(boolean expectNull) throws Exception {
        if (expectNull) {
          Thread.sleep(50);
          return template.receiveAndConvert("xdbus." + queue);
        }
        Object bar = null;
        int n = 0;
        while (n++ < 100 && bar == null) {
          bar = template.receiveAndConvert("xdbus." + queue);
View Full Code Here
515
516
517
518
519
520
521
522
523
524
525
          return template.receiveAndConvert("xdbus." + queue);
        }
        Object bar = null;
        int n = 0;
        while (n++ < 100 && bar == null) {
          bar = template.receiveAndConvert("xdbus." + queue);
          Thread.sleep(100);
        }
        assertTrue("Message did not arrive in RabbitMQ", n < 100);
        return bar;
      }
View Full Code Here
307
308
309
310
311
312
313
314
315
316
317
        assertTrue("Expected to receive all messages before stop", waited);
      }

      assertTrue("Not enough error handling, remaining:" + this.errorsHandled.getCount(),
          this.errorsHandled.await(10, TimeUnit.SECONDS));
      assertNull(template.receiveAndConvert(queue.getName()));
    }
    finally {
      container.shutdown();
    }
View Full Code Here
130
131
132
133
134
135
136
137
138
139
140
    int timeout = Math.min(4 + messageCount / (4 * concurrentConsumers), 30);
    logger.debug("Waiting for messages with timeout = " + timeout + " (s)");
    boolean waited = latch.await(timeout, TimeUnit.SECONDS);
    assertTrue("Timed out waiting for message", waited);

    assertNull(template.receiveAndConvert(queue.getName()));

  }

  private ConnectionFactory createConnectionFactory() {
    CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
View Full Code Here
166
167
168
169
170
171
172
173
174
175
176
    int timeout = Math.min(4 + messageCount / (4 * concurrentConsumers), 30);
    logger.debug("Waiting for messages with timeout = " + timeout + " (s)");
    waited = latch.await(timeout, TimeUnit.SECONDS);
    assertTrue("Timed out waiting for message", waited);

    assertNull(template.receiveAndConvert(queue.getName()));

  }

  private SimpleMessageListenerContainer createContainer(String queueName, Object listener,
      ConnectionFactory connectionFactory) {
View Full Code Here
60
61
62
63
64
65
66
67
68
69
70
    blockingQueueConsumer.start();

    // TODO: make this into a proper assertion. An exception can be thrown here by the Rabbit client and printed to
    // stderr without being rethrown (so hard to make a test fail).
    blockingQueueConsumer.stop();
    assertNull(template.receiveAndConvert(queue.getName()));
    connectionFactory.destroy();

  }

}
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.