fix: apply upstream bug fixes and resource leak patches from apache/plc4x

- fix(s7): S7HMuxImpl direct buffer leak per-message (PR apache#2542)
- fix(s7): alarm-query directBuffer not released in S7ProtocolLogic and S7NonHProtocolLogic (PR apache#2543)
- fix(s7,spi): decodeLargeReadResponse heap buffer not released in S7ProtocolLogic and S7NonHProtocolLogic
- feat(spi): SharedExecutor — JVM-scoped thread pools replace per-connection ThreadPoolExecutors to prevent thread accumulation on reconnect (PR apache#2281)
- fix(spi): RequestTransactionManager.shutdown() cancels in-flight requests without shutting down shared executor
- feat(spi): channelInactive lifecycle hook on Plc4xProtocolBase and Plc4xNettyWrapper; all drivers release resources on TCP disconnect (PR apache#2241)
- fix(eip): NPE in decodeSingleReadResponse when PLC returns error status and getData() is null (PR apache#2471)
- fix(umas): align pom version to 0.14.0.B-SNAPSHOT and fix RequestTransactionManager constructor call

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: spnettec

plc4j/drivers/ab-eth/src/main/java/org/apache/plc4x/java/abeth/protocol/AbEthProtocolLogic.java

@@ -214,4 +214,9 @@ private PlcResponseCode decodeResponseCode(short status) {
         return PlcResponseCode.NOT_FOUND;
     }
 
+    @Override
+    public void channelInactive(ConversationContext<CIPEncapsulationPacket> context) {
+        tm.shutdown();
+    }
+
 }

plc4j/drivers/ads/src/main/java/org/apache/plc4x/java/ads/protocol/AdsProtocolLogic.java

@@ -1985,4 +1985,9 @@ protected byte[] getNullByteTerminatedArray(String value) {
         return nullTerminatedBytes;
     }
 
+    @Override
+    public void channelInactive(ConversationContext<AmsTCPPacket> context) {
+        tm.shutdown();
+    }
+
 }

plc4j/drivers/bacnet/src/main/java/org/apache/plc4x/java/bacnetip/protocol/BacNetIpProtocolLogic.java

@@ -288,4 +288,9 @@ private String toString(BacNetIpTag tag) {
         return tag.getDeviceIdentifier() + "/" + tag.getObjectType() + "/" + tag.getObjectInstance();
     }
 
+    @Override
+    public void channelInactive(ConversationContext<BVLC> context) {
+        // Nothing to do here ...
+    }
+
 }

plc4j/drivers/c-bus/src/main/java/org/apache/plc4x/java/cbus/protocol/CBusProtocolLogic.java

@@ -78,4 +78,9 @@ public CompletableFuture<PlcReadResponse> read(PlcReadRequest readRequest) {
     protected void decode(ConversationContext<CBusCommand> context, CBusCommand msg) throws Exception {
     }
 
+    @Override
+    public void channelInactive(ConversationContext<CBusCommand> context) {
+        tm.shutdown();
+    }
+
 }

plc4j/drivers/can/src/main/java/org/apache/plc4x/java/can/adapter/CANDriverAdapter.java

@@ -113,4 +113,9 @@ public void close(ConversationContext<C> context) {
         delegate.close(new ConversationContextWrapper<>(context, wireType, adapter, frameHandler, context.getAuthentication()));
     }
 
+    @Override
+    public void channelInactive(ConversationContext<C> context) {
+        delegate.channelInactive(new ConversationContextWrapper<>(context, wireType, adapter, frameHandler, context.getAuthentication()));
+    }
+
 }

plc4j/drivers/can/src/main/java/org/apache/plc4x/java/can/generic/protocol/GenericCANProtocolLogic.java

@@ -235,4 +235,9 @@ public PlcConsumerRegistration register(Consumer<PlcSubscriptionEvent> consumer,
     public void unregister(PlcConsumerRegistration registration) {
         consumers.remove(registration);
     }
+
+    @Override
+    public void channelInactive(ConversationContext<GenericFrame> context) {
+        tm.shutdown();
+    }
 }

plc4j/drivers/canopen/src/main/java/org/apache/plc4x/java/canopen/protocol/CANOpenProtocolLogic.java

@@ -480,4 +480,9 @@ public void onDisconnect(ConversationContext<CANOpenFrame> context) {
         }
     }
 
+    @Override
+    public void channelInactive(ConversationContext<CANOpenFrame> context) {
+        tm.shutdown();
+    }
+
 }

plc4j/drivers/eip/src/main/java/org/apache/plc4x/java/eip/base/protocol/EipProtocolLogic.java

@@ -811,9 +811,9 @@ private Map<String, PlcResponseItem<PlcValue>> decodeSingleReadResponse(CipServi
         CipReadResponse resp = (CipReadResponse) p;
         PlcResponseCode code = decodeResponseCode(resp.getStatus());
         PlcValue plcValue = null;
-        CIPDataTypeCode type = resp.getData().getDataType();
-        ByteBuf data = Unpooled.wrappedBuffer(resp.getData().getData());
         if (code == PlcResponseCode.OK) {
+            CIPDataTypeCode type = resp.getData().getDataType();
+            ByteBuf data = Unpooled.wrappedBuffer(resp.getData().getData());
             plcValue = parsePlcValue((EipTag) tag, data, type);
         }
         PlcResponseItem<PlcValue> result = new DefaultPlcResponseItem<>(code, plcValue);
@@ -1355,4 +1355,9 @@ private PlcResponseCode decodeResponseCode(int status) {
         }
     }
 
+    @Override
+    public void channelInactive(ConversationContext<EipPacket> context) {
+        tm.shutdown();
+    }
+
 }

plc4j/drivers/firmata/src/main/java/org/apache/plc4x/java/firmata/readwrite/protocol/FirmataProtocolLogic.java

@@ -320,4 +320,9 @@ protected BitSet getDigitalValues(int byteBlock, List<Byte> data) {
         return BitSet.valueOf(bitSetData);
     }
 
+    @Override
+    public void channelInactive(ConversationContext<FirmataMessage> context) {
+        connected.set(false);
+    }
+
 }

plc4j/drivers/iec-60870/src/main/java/org/apache/plc4x/java/iec608705104/readwrite/protocol/Iec608705104Protocol.java

@@ -235,4 +235,9 @@ protected void publishEvent(LocalDateTime timeStamp, Iec608705104Tag tag, PlcVal
         }
     }
 
+    @Override
+    public void channelInactive(ConversationContext<APDU> context) {
+        tm.shutdown();
+    }
+
 }