CAMEL-9049: Modifying timing that Jetty connector added and removed
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/dc08c76e Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/dc08c76e Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/dc08c76e Branch: refs/heads/camel-2.14.x Commit: dc08c76e758dab8619b337b13d36d1be984a3f02 Parents: 93cdc37 Author: Andrew Block <[email protected]> Authored: Sat Aug 8 14:40:57 2015 -0500 Committer: Claus Ibsen <[email protected]> Committed: Sun Aug 9 10:00:05 2015 +0200 ---------------------------------------------------------------------- .../apache/camel/component/websocket/WebsocketConsumer.java | 8 ++++---- .../apache/camel/component/websocket/WebsocketProducer.java | 8 ++++---- 2 files changed, 8 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/dc08c76e/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketConsumer.java b/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketConsumer.java index d197e0c..68953d4 100644 --- a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketConsumer.java +++ b/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketConsumer.java @@ -31,15 +31,15 @@ public class WebsocketConsumer extends DefaultConsumer implements WebsocketProdu } @Override - public void start() throws Exception { - super.start(); + public void doStart() throws Exception { + super.doStart(); endpoint.connect(this); } @Override - public void stop() throws Exception { + public void doStop() throws Exception { endpoint.disconnect(this); - super.stop(); + super.doStop(); } public WebsocketEndpoint getEndpoint() { http://git-wip-us.apache.org/repos/asf/camel/blob/dc08c76e/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketProducer.java b/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketProducer.java index b00fc79..18b0775 100644 --- a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketProducer.java +++ b/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketProducer.java @@ -65,15 +65,15 @@ public class WebsocketProducer extends DefaultProducer implements WebsocketProdu @Override - public void start() throws Exception { - super.start(); + public void doStart() throws Exception { + super.doStart(); endpoint.connect(this); } @Override - public void stop() throws Exception { + public void doStop() throws Exception { endpoint.disconnect(this); - super.stop(); + super.doStop(); } boolean isSendToAllSet(Message in) {
