List of receiveAndConvert() Examples

Examples of receiveAndConvert()

org.springframework.amqp.core.AmqpTemplate.receiveAndConvert()
Receive a message if there is one from a default queue and convert it to a Java object. Returns immediately, possibly with a null value. @return a message or null if there is none waiting @throws AmqpException if there is a problem
org.springframework.amqp.rabbit.core.RabbitTemplate.receiveAndConvert()
org.springframework.integration.core.MessagingTemplate.receiveAndConvert()
org.springframework.jms.core.JmsOperations.receiveAndConvert()
Receive a message synchronously from the default destination, but only wait up to a specified time for delivery. Convert the message into an object with a configured MessageConverter.
This method should be used carefully, since it will block the thread until the message becomes available or until the timeout value is exceeded.
This will only work with a default destination specified! @return the message produced for the consumer or null if the timeout expires. @throws JmsException checked JMSException converted to unchecked
org.springframework.jms.core.JmsTemplate.receiveAndConvert()

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

    int timeout = getTimeout();
    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()));


    assertEquals(concurrentConsumers, container.getActiveConsumerCount());
    container.stop();
    assertEquals(0, container.getActiveConsumerCount());

View Full Code Here

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

    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()));


    ((DisposableBean) connectionFactory1).destroy();
    ((DisposableBean) connectionFactory2).destroy();


  }

View Full Code Here

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

    int timeout = getTimeout();
    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()));


    ((DisposableBean) connectionFactory).destroy();


  }

View Full Code Here

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

    }
    finally {
      container.shutdown();
      assertEquals(0, container.getActiveConsumerCount());
    }
    assertNull(template.receiveAndConvert(queue1.getName()));
    assertNull(template.receiveAndConvert(queue2.getName()));


    connectionFactory.destroy();
  }

View Full Code Here

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

    finally {
      container.shutdown();
      assertEquals(0, container.getActiveConsumerCount());
    }
    assertNull(template.receiveAndConvert(queue1.getName()));
    assertNull(template.receiveAndConvert(queue2.getName()));


    connectionFactory.destroy();
  }

View Full Code Here

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

    template.convertAndSend(fanoutTest.getName(), "", "message");
    template.convertAndSend(fanoutTest.getName(), queue.getName(), "message");
    Thread.sleep(200);
    // The queue is anonymous so it will be deleted at the end of the test, but it should get the message as long as
    // we use the same connection
    String result = (String) template.receiveAndConvert(queue.getName());
    assertEquals("message", result);
    result = (String) template.receiveAndConvert(queue.getName());
    assertEquals("message", result);
  }

View Full Code Here

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

    Thread.sleep(200);
    // The queue is anonymous so it will be deleted at the end of the test, but it should get the message as long as
    // we use the same connection
    String result = (String) template.receiveAndConvert(queue.getName());
    assertEquals("message", result);
    result = (String) template.receiveAndConvert(queue.getName());
    assertEquals("message", result);
  }


  @Test
  public void testDirectExchangeBindings() throws Exception {

View Full Code Here

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

    RabbitTemplate template = new RabbitTemplate(connectionFactory);


    template.convertAndSend(directTest.getName(), queue.getName(), "message");
    Thread.sleep(200);


    String result = (String) template.receiveAndConvert(queue.getName());
    assertEquals("message", result);


    template.convertAndSend(directTest.getName(), "", "message2");
    Thread.sleep(200);

View Full Code Here

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

    assertEquals("message", result);


    template.convertAndSend(directTest.getName(), "", "message2");
    Thread.sleep(200);


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


    result = (String) template.receiveAndConvert(queue2.getName());
    assertEquals("message2", result);


    template.convertAndSend(directTest.getName(), queue2.getName(), "message2");

View Full Code Here

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

    template.convertAndSend(directTest.getName(), "", "message2");
    Thread.sleep(200);


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


    result = (String) template.receiveAndConvert(queue2.getName());
    assertEquals("message2", result);


    template.convertAndSend(directTest.getName(), queue2.getName(), "message2");
    Thread.sleep(200);

View Full Code Here

0 1 2 3 4 5

TOP

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.