You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@plc4x.apache.org by jf...@apache.org on 2020/08/12 07:28:13 UTC

[plc4x] branch develop updated: Added working version.

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

jfeinauer pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/plc4x.git


The following commit(s) were added to refs/heads/develop by this push:
     new 838638e  Added working version.
838638e is described below

commit 838638ea532ba802f3053420a889a728adc7ee99
Author: Julian Feinauer <j....@pragmaticminds.de>
AuthorDate: Wed Aug 12 09:26:22 2020 +0200

    Added working version.
---
 .../src/main/java/org/apache/plc4x/java/amsads/AMSADSPlcDriver.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/sandbox/test-java-amsads-driver/src/main/java/org/apache/plc4x/java/amsads/AMSADSPlcDriver.java b/sandbox/test-java-amsads-driver/src/main/java/org/apache/plc4x/java/amsads/AMSADSPlcDriver.java
index a98d2e6..7cda7d0 100644
--- a/sandbox/test-java-amsads-driver/src/main/java/org/apache/plc4x/java/amsads/AMSADSPlcDriver.java
+++ b/sandbox/test-java-amsads-driver/src/main/java/org/apache/plc4x/java/amsads/AMSADSPlcDriver.java
@@ -28,6 +28,7 @@ import org.apache.plc4x.java.amsads.protocol.AdsProtocolLogic;
 import org.apache.plc4x.java.amsads.readwrite.AmsPacket;
 import org.apache.plc4x.java.amsads.readwrite.io.AmsPacketIO;
 import org.apache.plc4x.java.spi.GeneratedDriverByteToMessageCodec;
+import org.apache.plc4x.java.spi.Plc4xNettyWrapper;
 import org.apache.plc4x.java.spi.Plc4xProtocolBase;
 import org.apache.plc4x.java.spi.configuration.Configuration;
 import org.apache.plc4x.java.spi.connection.GeneratedDriverBase;
@@ -113,7 +114,7 @@ public class AMSADSPlcDriver extends GeneratedDriverBase<AmsPacket> {
 
                 System.out.println(aClass);
 
-                if (entry.getValue() instanceof GeneratedDriverByteToMessageCodec) {
+                if (entry.getValue() instanceof Plc4xNettyWrapper) {
                     // Found handler
                     pipeline.addBefore(entry.getKey(), "idempotent-layer", new MessageToMessageCodec() {
                         @Override