Repository: camel Updated Branches: refs/heads/master 08d185c22 -> 7ad8a7e16
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/debe667f Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/debe667f Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/debe667f Branch: refs/heads/master Commit: debe667f149e13ca8152ef2072aa3536fae58a59 Parents: 08d185c Author: Andrew Block <[email protected]> Authored: Sat Aug 8 14:40:57 2015 -0500 Committer: Claus Ibsen <[email protected]> Committed: Sun Aug 9 09:06:48 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/debe667f/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/debe667f/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) {
