This is an automated email from the ASF dual-hosted git repository. sruehl pushed a commit to branch feature/TopLevelItemSpliting in repository https://gitbox.apache.org/repos/asf/incubator-plc4x.git
commit 9e25460948d2769638d79dc792ff4b157f5e1789 Author: Sebastian Rühl <sru...@apache.org> AuthorDate: Wed Sep 26 18:07:56 2018 +0200 [General] SingleItemToSingleRequestProtocol implemented ErrorHandler --- .../plc4x/java/base/protocol/SingleItemToSingleRequestProtocol.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/plc4j/protocols/driver-bases/base/src/main/java/org/apache/plc4x/java/base/protocol/SingleItemToSingleRequestProtocol.java b/plc4j/protocols/driver-bases/base/src/main/java/org/apache/plc4x/java/base/protocol/SingleItemToSingleRequestProtocol.java index 267f9a8..0fdebf5 100644 --- a/plc4j/protocols/driver-bases/base/src/main/java/org/apache/plc4x/java/base/protocol/SingleItemToSingleRequestProtocol.java +++ b/plc4j/protocols/driver-bases/base/src/main/java/org/apache/plc4x/java/base/protocol/SingleItemToSingleRequestProtocol.java @@ -118,7 +118,11 @@ public class SingleItemToSingleRequestProtocol extends ChannelDuplexHandler { } private void errored(int correlationId, Throwable throwable) { - + PlcRequestContainer<InternalPlcRequest, InternalPlcResponse<?>> plcRequestContainer = sentButUnacknowledgedRequestItems.remove(correlationId); + if (plcRequestContainer == null) { + throw new PlcRuntimeException("Unrelated error received ", throwable); + } + plcRequestContainer.getResponseFuture().completeExceptionally(throwable); } ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////