diff options
Diffstat (limited to 'qpid/java/broker-plugins/websocket')
| -rw-r--r-- | qpid/java/broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/WebSocketProvider.java | 7 |
1 files changed, 6 insertions, 1 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 fde93a27e3..81dcb05a41 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 @@ -28,6 +28,7 @@ import org.apache.qpid.server.model.Transport; import org.apache.qpid.server.protocol.AmqpProtocolVersion; import org.apache.qpid.server.protocol.MultiVersionProtocolEngineFactory; import org.apache.qpid.server.transport.AcceptingTransport; +import org.apache.qpid.server.util.ServerScopedRuntimeException; import org.apache.qpid.transport.Binary; import org.apache.qpid.transport.Sender; import org.apache.qpid.transport.network.NetworkConnection; @@ -144,9 +145,13 @@ class WebSocketProvider implements AcceptingTransport { _server.start(); } + catch(RuntimeException e) + { + throw e; + } catch (Exception e) { - throw new RuntimeException(e); + throw new ServerScopedRuntimeException(e); } } |