You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@plc4x.apache.org by sr...@apache.org on 2018/06/21 09:46:43 UTC
[incubator-plc4x] 01/03: BUGFIX: receive behaves differently on
receive without a timeout
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 <sr...@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);
}