CAMEL-6506 added set server listeners to CommetdComponent with thanks to Jatin
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/af357f01 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/af357f01 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/af357f01 Branch: refs/heads/master Commit: af357f01747dc3f22d1f091c6db82955e8dc1a62 Parents: 8860867 Author: Willem Jiang <ningji...@apache.org> Authored: Wed Jul 3 09:53:26 2013 +0800 Committer: Willem Jiang <ningji...@apache.org> Committed: Wed Jul 3 09:53:26 2013 +0800 ---------------------------------------------------------------------- .../apache/camel/component/cometd/CometdComponent.java | 13 +++++++++++++ 1 file changed, 13 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/af357f01/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdComponent.java ---------------------------------------------------------------------- diff --git a/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdComponent.java b/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdComponent.java index f264e62..fd7d7bb 100644 --- a/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdComponent.java +++ b/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdComponent.java @@ -64,6 +64,7 @@ public class CometdComponent extends DefaultComponent { private String sslKeystore; private SecurityPolicy securityPolicy; private List<BayeuxServer.Extension> extensions; + private List<BayeuxServer.BayeuxServerListener> serverListeners; private SSLContextParameters sslContextParameters; class ConnectorRef { @@ -142,6 +143,11 @@ public class CometdComponent extends DefaultComponent { bayeux.addExtension(extension); } } + if (serverListeners != null) { + for (BayeuxServer.BayeuxServerListener serverListener : serverListeners) { + bayeux.addListener(serverListener); + } + } prodcon.setBayeux(bayeux); } } @@ -284,6 +290,13 @@ public class CometdComponent extends DefaultComponent { extensions.add(extension); } + public void addServerListener(BayeuxServer.BayeuxServerListener serverListener) { + if (serverListeners == null) { + serverListeners = new ArrayList<BayeuxServer.BayeuxServerListener>(); + } + serverListeners.add(serverListener); + } + public SSLContextParameters getSslContextParameters() { return sslContextParameters; }
