From d9f88f0fe282c7c9c76e4f9054e353ce86a5aea8 Mon Sep 17 00:00:00 2001 From: Kevin Herron Date: Sun, 15 Feb 2026 05:45:01 -0800 Subject: [PATCH] Add getSerialPort() to serial port transports --- .../modbus/serial/client/SerialPortClientTransport.java | 9 +++++++++ .../modbus/serial/server/SerialPortServerTransport.java | 9 +++++++++ 2 files changed, 18 insertions(+) diff --git a/modbus-serial/src/main/java/com/digitalpetri/modbus/serial/client/SerialPortClientTransport.java b/modbus-serial/src/main/java/com/digitalpetri/modbus/serial/client/SerialPortClientTransport.java index 0dc6eab..a7b8c24 100644 --- a/modbus-serial/src/main/java/com/digitalpetri/modbus/serial/client/SerialPortClientTransport.java +++ b/modbus-serial/src/main/java/com/digitalpetri/modbus/serial/client/SerialPortClientTransport.java @@ -46,6 +46,15 @@ public SerialPortClientTransport(SerialPortTransportConfig config) { executionQueue = new ExecutionQueue(config.executor()); } + /** + * Return the underlying {@link SerialPort} used by this transport. + * + * @return the configured {@link SerialPort} instance. + */ + public SerialPort getSerialPort() { + return serialPort; + } + @Override public synchronized CompletableFuture connect() { if (serialPort.isOpen()) { diff --git a/modbus-serial/src/main/java/com/digitalpetri/modbus/serial/server/SerialPortServerTransport.java b/modbus-serial/src/main/java/com/digitalpetri/modbus/serial/server/SerialPortServerTransport.java index d64cd50..b882035 100644 --- a/modbus-serial/src/main/java/com/digitalpetri/modbus/serial/server/SerialPortServerTransport.java +++ b/modbus-serial/src/main/java/com/digitalpetri/modbus/serial/server/SerialPortServerTransport.java @@ -54,6 +54,15 @@ public SerialPortServerTransport(SerialPortTransportConfig config) { executionQueue = new ExecutionQueue(config.executor()); } + /** + * Return the underlying {@link SerialPort} used by this transport. + * + * @return the configured {@link SerialPort} instance. + */ + public SerialPort getSerialPort() { + return serialPort; + } + @Override public CompletionStage bind() { if (serialPort.isOpen()) {