You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2013/07/03 03:59:31 UTC
[2/3] git commit: CAMEL-6506 added set server listeners to
CommetdComponent with thanks to Jatin
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 <ni...@apache.org>
Authored: Wed Jul 3 09:53:26 2013 +0800
Committer: Willem Jiang <ni...@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;
}