Repository: qpid-jms Updated Branches: refs/heads/master ee6b246c7 -> b88ad6698
Make the options visible at the interface level to aid in tests. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/f6d84634 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/f6d84634 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/f6d84634 Branch: refs/heads/master Commit: f6d84634f8ac32b16232ee129e6c8b2fd85cda32 Parents: ee6b246 Author: Timothy Bish <[email protected]> Authored: Fri Jan 23 10:55:37 2015 -0500 Committer: Timothy Bish <[email protected]> Committed: Fri Jan 23 11:14:02 2015 -0500 ---------------------------------------------------------------------- .../src/main/java/org/apache/qpid/jms/transports/Transport.java | 5 +++++ .../org/apache/qpid/jms/transports/netty/NettyTcpTransport.java | 1 + .../org/apache/qpid/jms/transports/plain/PlainTcpTransport.java | 1 + .../java/org/apache/qpid/jms/transports/vertx/TcpTransport.java | 1 + 4 files changed, 8 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/f6d84634/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/Transport.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/Transport.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/Transport.java index 9a95234..1ed52cc 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/Transport.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/Transport.java @@ -73,4 +73,9 @@ public interface Transport { */ void setTransportListener(TransportListener listener); + /** + * @returns the TransportOptions instance that holds the configuration for this Transport. + */ + TransportOptions getTransportOptions(); + } http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/f6d84634/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/netty/NettyTcpTransport.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/netty/NettyTcpTransport.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/netty/NettyTcpTransport.java index 0a6e0b5..3fab4b6 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/netty/NettyTcpTransport.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/netty/NettyTcpTransport.java @@ -181,6 +181,7 @@ public class NettyTcpTransport implements Transport { this.listener = listener; } + @Override public TransportOptions getTransportOptions() { if (options == null) { options = TransportOptions.DEFAULT_OPTIONS; http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/f6d84634/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/plain/PlainTcpTransport.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/plain/PlainTcpTransport.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/plain/PlainTcpTransport.java index 2adc685..8780312 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/plain/PlainTcpTransport.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/plain/PlainTcpTransport.java @@ -216,6 +216,7 @@ public class PlainTcpTransport implements Transport, Runnable { this.listener = listener; } + @Override public TransportOptions getTransportOptions() { if (options == null) { options = TransportOptions.DEFAULT_OPTIONS; http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/f6d84634/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/vertx/TcpTransport.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/vertx/TcpTransport.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/vertx/TcpTransport.java index e90bd0b..332dacc 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/vertx/TcpTransport.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/vertx/TcpTransport.java @@ -228,6 +228,7 @@ public class TcpTransport implements Transport { /** * @return the options used to configure the TCP socket. */ + @Override public TransportOptions getTransportOptions() { if (options == null) { options = TransportOptions.DEFAULT_OPTIONS; --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
