diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2014-10-17 19:41:37 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2014-10-17 19:41:37 +0000 |
| commit | 9006d5e2237751a43b8d531980e9b1499acb96d6 (patch) | |
| tree | cebe936d36a7a7d41112dc475e70daccb2c5a250 /qpid/java/broker-plugins/websocket/src | |
| parent | 7d2471990e0271d4714cf493643be67165d03834 (diff) | |
| download | qpid-python-9006d5e2237751a43b8d531980e9b1499acb96d6.tar.gz | |
QPID-6165 : [Java Broker] Allow the number of open connections to be limited on a per port basis
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1632655 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker-plugins/websocket/src')
| -rw-r--r-- | qpid/java/broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/WebSocketProvider.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/qpid/java/broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/WebSocketProvider.java b/qpid/java/broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/WebSocketProvider.java index 8e250ef669..5f025313e8 100644 --- a/qpid/java/broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/WebSocketProvider.java +++ b/qpid/java/broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/WebSocketProvider.java @@ -60,7 +60,7 @@ class WebSocketProvider implements AcceptingTransport public static final String AMQP_WEBSOCKET_SUBPROTOCOL = "AMQPWSB10"; private final Transport _transport; private final SSLContext _sslContext; - private final Port<?> _port; + private final AmqpPort<?> _port; private final Set<Protocol> _supported; private final Protocol _defaultSupportedProtocolReply; private final ProtocolEngineFactory _factory; @@ -68,7 +68,7 @@ class WebSocketProvider implements AcceptingTransport WebSocketProvider(final Transport transport, final SSLContext sslContext, - final Port<?> port, + final AmqpPort<?> port, final Set<Protocol> supported, final Protocol defaultSupportedProtocolReply) { @@ -207,7 +207,7 @@ class WebSocketProvider implements AcceptingTransport { _connection = connection; - _engine = _factory.newProtocolEngine(); + _engine = _factory.newProtocolEngine(_remoteAddress); final ConnectionWrapper connectionWrapper = new ConnectionWrapper(connection, _localAddress, _remoteAddress); |