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()) {