[camel] 09/11: Fixed camel-hazelcast consumer should store message body on IN and not out

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git

commit f3157b28de18af90a4602430fcdb0b16723a21f8
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Sun Aug 23 10:25:00 2020 +0200

    Fixed camel-hazelcast consumer should store message body on IN and not out
---
 .../apache/camel/component/hazelcast/queue/HazelcastQueueConsumer.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueConsumer.java
 
b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueConsumer.java
index 6f598e6..4fa6948 100644
--- 
a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueConsumer.java
+++ 
b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueConsumer.java
@@ -85,7 +85,7 @@ public class HazelcastQueueConsumer extends 
HazelcastDefaultConsumer {
                     try {
                         final Object body = 
queue.poll(config.getPollingTimeout(), TimeUnit.MILLISECONDS);
                         Exchange exchange = getEndpoint().createExchange();
-                        exchange.getOut().setBody(body);
+                        exchange.getIn().setBody(body);
                         try {
                             processor.process(exchange);
                         } catch (Exception e) {