This is an automated email from the ASF dual-hosted git repository. sruehl pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-plc4x.git
commit 97245e2c5d17f2157f3ca256fa6cd59c5617708b Author: Sebastian Rühl <sru...@apache.org> AuthorDate: Thu Jun 21 10:55:45 2018 +0200 BUGFIX: receive behaves differently on receive without a timeout --- .../src/main/java/org/apache/plc4x/camel/Plc4XPollingConsumer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/integrations/apache-camel/src/main/java/org/apache/plc4x/camel/Plc4XPollingConsumer.java b/integrations/apache-camel/src/main/java/org/apache/plc4x/camel/Plc4XPollingConsumer.java index e9c5406..603f76e 100644 --- a/integrations/apache-camel/src/main/java/org/apache/plc4x/camel/Plc4XPollingConsumer.java +++ b/integrations/apache-camel/src/main/java/org/apache/plc4x/camel/Plc4XPollingConsumer.java @@ -82,7 +82,7 @@ public class Plc4XPollingConsumer extends ServiceSupport implements PollingConsu CompletableFuture<? extends PlcReadResponse> read = getReader().read(new PlcReadRequest(dataType, address)); try { PlcReadResponse plcReadResponse = read.get(); - exchange.getIn().setBody(plcReadResponse.getResponseItems()); + exchange.getIn().setBody(unwrapIfSingle(plcReadResponse.getResponseItems())); } catch (InterruptedException | ExecutionException e) { exchange.setException(e); }