public class CometdComponent
extends org.apache.camel.impl.UriEndpointComponent
Constructor and Description |
---|
CometdComponent() |
Modifier and Type | Method and Description |
---|---|
void |
addExtension(org.cometd.bayeux.server.BayeuxServer.Extension extension) |
void |
addServerListener(org.cometd.bayeux.server.BayeuxServer.BayeuxServerListener serverListener) |
void |
connect(CometdProducerConsumer prodcon)
Connects the URL specified on the endpoint to the specified processor.
|
protected org.apache.camel.Endpoint |
createEndpoint(String uri,
String remaining,
Map<String,Object> parameters) |
protected org.eclipse.jetty.server.Server |
createServer() |
protected org.cometd.server.CometDServlet |
createServletForConnector(org.eclipse.jetty.server.Server server,
org.eclipse.jetty.server.Connector connector,
CometdEndpoint endpoint) |
void |
disconnect(CometdProducerConsumer prodcon)
Disconnects the URL specified on the endpoint from the specified
processor.
|
protected void |
doStart() |
protected void |
doStop() |
List<org.cometd.bayeux.server.BayeuxServer.Extension> |
getExtensions() |
org.cometd.bayeux.server.SecurityPolicy |
getSecurityPolicy() |
org.apache.camel.util.jsse.SSLContextParameters |
getSslContextParameters() |
String |
getSslKeyPassword() |
String |
getSslKeystore() |
String |
getSslPassword() |
protected org.eclipse.jetty.server.ServerConnector |
getSslSocketConnector(org.eclipse.jetty.server.Server server) |
void |
setExtensions(List<org.cometd.bayeux.server.BayeuxServer.Extension> extensions)
To use a list of custom BayeuxServer.Extension that allows modifying incoming and outgoing requests.
|
void |
setSecurityPolicy(org.cometd.bayeux.server.SecurityPolicy securityPolicy)
To use a custom configured SecurityPolicy to control authorization
|
void |
setSslContextParameters(org.apache.camel.util.jsse.SSLContextParameters sslContextParameters)
To configure security using SSLContextParameters
|
void |
setSslKeyPassword(String sslKeyPassword)
The password for the keystore when using SSL.
|
void |
setSslKeystore(String sslKeystore)
The path to the keystore.
|
void |
setSslPassword(String sslPassword)
The password when using SSL.
|
createComponentConfiguration, createParameterConfigurationMap, getEndpointClass, getParameterConfigurationMap, populateParameterConfigurationMap, setEndpointClass
afterConfiguration, createConfiguration, createEndpoint, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, ifStartsWithReturnRemainder, preProcessUri, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, setProperties, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI
protected org.apache.camel.Endpoint createEndpoint(String uri, String remaining, Map<String,Object> parameters) throws Exception
createEndpoint
in class org.apache.camel.impl.DefaultComponent
Exception
public void connect(CometdProducerConsumer prodcon) throws Exception
Exception
public void disconnect(CometdProducerConsumer prodcon) throws Exception
Exception
protected org.cometd.server.CometDServlet createServletForConnector(org.eclipse.jetty.server.Server server, org.eclipse.jetty.server.Connector connector, CometdEndpoint endpoint) throws Exception
Exception
protected org.eclipse.jetty.server.ServerConnector getSslSocketConnector(org.eclipse.jetty.server.Server server) throws Exception
Exception
public String getSslKeyPassword()
public String getSslPassword()
public String getSslKeystore()
public void setSslKeyPassword(String sslKeyPassword)
public void setSslPassword(String sslPassword)
public void setSslKeystore(String sslKeystore)
public void setSecurityPolicy(org.cometd.bayeux.server.SecurityPolicy securityPolicy)
public org.cometd.bayeux.server.SecurityPolicy getSecurityPolicy()
public List<org.cometd.bayeux.server.BayeuxServer.Extension> getExtensions()
public void setExtensions(List<org.cometd.bayeux.server.BayeuxServer.Extension> extensions)
public void addExtension(org.cometd.bayeux.server.BayeuxServer.Extension extension)
public void addServerListener(org.cometd.bayeux.server.BayeuxServer.BayeuxServerListener serverListener)
public org.apache.camel.util.jsse.SSLContextParameters getSslContextParameters()
public void setSslContextParameters(org.apache.camel.util.jsse.SSLContextParameters sslContextParameters)
protected org.eclipse.jetty.server.Server createServer() throws Exception
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultComponent
Exception
Apache Camel