diff options
Diffstat (limited to 'java/newclient/src/main/java/org/apache/qpid/nclient/transport/TransportPhase.java')
| -rw-r--r-- | java/newclient/src/main/java/org/apache/qpid/nclient/transport/TransportPhase.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/java/newclient/src/main/java/org/apache/qpid/nclient/transport/TransportPhase.java b/java/newclient/src/main/java/org/apache/qpid/nclient/transport/TransportPhase.java index 911e855d4f..2c618cfe81 100644 --- a/java/newclient/src/main/java/org/apache/qpid/nclient/transport/TransportPhase.java +++ b/java/newclient/src/main/java/org/apache/qpid/nclient/transport/TransportPhase.java @@ -44,7 +44,7 @@ import org.apache.qpid.framing.ProtocolVersionList; import org.apache.qpid.nclient.config.ClientConfiguration; import org.apache.qpid.nclient.core.AMQPException; import org.apache.qpid.nclient.core.AbstractPhase; -import org.apache.qpid.nclient.core.QpidConstants; +import org.apache.qpid.nclient.core.AMQPConstants; import org.apache.qpid.pool.ReadWriteThreadModel; import org.apache.qpid.ssl.BogusSSLContextFactory; @@ -72,8 +72,8 @@ public class TransportPhase extends AbstractPhase implements IoHandler, Protocol public void start()throws AMQPException { - _brokerDetails = (BrokerDetails)_ctx.getProperty(QpidConstants.AMQP_BROKER_DETAILS); - IoConnector ioConnector = (IoConnector)_ctx.getProperty(QpidConstants.MINA_IO_CONNECTOR); + _brokerDetails = (BrokerDetails)_ctx.getProperty(AMQPConstants.AMQP_BROKER_DETAILS); + IoConnector ioConnector = (IoConnector)_ctx.getProperty(AMQPConstants.MINA_IO_CONNECTOR); final SocketAddress address; if (ioConnector instanceof VmPipeConnector) @@ -179,7 +179,7 @@ public class TransportPhase extends AbstractPhase implements IoHandler, Protocol new AMQCodecFactory(false)); if (ClientConfiguration.get().getBoolean( - QpidConstants.USE_SHARED_READ_WRITE_POOL)) + AMQPConstants.USE_SHARED_READ_WRITE_POOL)) { session.getFilterChain().addBefore("AsynchronousWriteFilter", "protocolFilter", pcf); |