Examples of toMessageProperties()


Examples of org.springframework.amqp.rabbit.support.DefaultMessagePropertiesConverter.toMessageProperties()

      @Override
      public String doInRabbit(Channel channel) throws Exception {
        // We need noAck=false here for the message to be expicitly
        // acked
        GetResponse response = channel.basicGet(ROUTE, false);
        MessageProperties messageProps = messagePropertiesConverter.toMessageProperties(
            response.getProps(), response.getEnvelope(), "UTF-8");
        // Explicit ack
        channel.basicAck(response.getEnvelope().getDeliveryTag(), false);
        return (String) new SimpleMessageConverter().fromMessage(new Message(response.getBody(), messageProps));
      }
View Full Code Here

Examples of org.springframework.amqp.rabbit.support.MessagePropertiesConverter.toMessageProperties()

      @Override
      public String doInRabbit(Channel channel) throws Exception {
        // We need noAck=false here for the message to be expicitly
        // acked
        GetResponse response = channel.basicGet(ROUTE, false);
        MessageProperties messageProps = messagePropertiesConverter.toMessageProperties(
            response.getProps(), response.getEnvelope(), "UTF-8");
        // Explicit ack
        channel.basicAck(response.getEnvelope().getDeliveryTag(), false);
        return (String) new SimpleMessageConverter().fromMessage(new Message(response.getBody(), messageProps));
      }
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.