diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2015-02-01 15:18:17 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2015-02-01 15:18:17 +0000 |
| commit | 50876b8a80c5bfd4ba125f87e07fe77669520c80 (patch) | |
| tree | 1e1a28291299870ac58b658270ec16e42fe5de9e /qpid/java/broker-core | |
| parent | e8a5ab04596ff422b3609cf1c454bdc76b473399 (diff) | |
| download | qpid-python-50876b8a80c5bfd4ba125f87e07fe77669520c80.tar.gz | |
Reduce copying in 0-9 path
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1656312 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker-core')
| -rw-r--r-- | qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/TCPandSSLTransport.java | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/TCPandSSLTransport.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/TCPandSSLTransport.java index 2fd10e4de4..8970df434a 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/TCPandSSLTransport.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/TCPandSSLTransport.java @@ -34,13 +34,12 @@ import org.apache.qpid.server.model.Transport; import org.apache.qpid.server.model.port.AmqpPort; import org.apache.qpid.server.protocol.MultiVersionProtocolEngineFactory; import org.apache.qpid.transport.NetworkTransportConfiguration; -import org.apache.qpid.transport.network.IncomingNetworkTransport; import org.apache.qpid.transport.network.TransportEncryption; import org.apache.qpid.transport.network.io.NonBlockingNetworkTransport; class TCPandSSLTransport implements AcceptingTransport { - private IncomingNetworkTransport _networkTransport; + private NonBlockingNetworkTransport _networkTransport; private Set<Transport> _transports; private SSLContext _sslContext; private InetSocketAddress _bindingSocketAddress; @@ -64,7 +63,7 @@ class TCPandSSLTransport implements AcceptingTransport @Override public void start() { - String bindingAddress = ((AmqpPort<?>)_port).getBindingAddress(); + String bindingAddress = _port.getBindingAddress(); if (WILDCARD_ADDRESS.equals(bindingAddress)) { bindingAddress = null; |