[incubator-streampipes-extensions] branch dev updated: Add close connection to plc4x adapter

[ze...@apache.org]

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

zehnder pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git


The following commit(s) were added to refs/heads/dev by this push:
     new d21aa72  Add close connection to plc4x adapter
d21aa72 is described below

commit d21aa727d7bed96f00045c3c753a22cd050f5f3a
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Thu Nov 19 07:15:35 2020 +0100

    Add close connection to plc4x adapter
---
 .../org/apache/streampipes/connect/adapters/plc4x/s7/Plc4xS7Adapter.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/plc4x/s7/Plc4xS7Adapter.java b/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/plc4x/s7/Plc4xS7Adapter.java
index 176e88e..da6ef8e 100644
--- a/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/plc4x/s7/Plc4xS7Adapter.java
+++ b/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/plc4x/s7/Plc4xS7Adapter.java
@@ -241,6 +241,7 @@ public class Plc4xS7Adapter extends PullAdapter {
 
                 // publish the final event
                 adapterPipeline.process(event);
+                plcConnection.close();
             } catch (InterruptedException | ExecutionException e) {
                 LOG.error(e.getMessage());
                 e.printStackTrace();