public class CometdComponent
extends org.apache.camel.impl.UriEndpointComponent
implements org.apache.camel.SSLContextParametersAware
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) |
boolean |
isUseGlobalSslContextParameters() |
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.
|
void |
setUseGlobalSslContextParameters(boolean useGlobalSslContextParameters)
Enable usage of global SSL context parameters.
|
createComponentConfiguration, createParameterConfigurationMap, getEndpointClass, getParameterConfigurationMap, populateParameterConfigurationMap, setEndpointClass
afterConfiguration, createConfiguration, createEndpoint, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, getExtension, getSupportedExtensions, ifStartsWithReturnRemainder, isResolvePropertyPlaceholders, preProcessUri, registerExtension, registerExtension, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, setProperties, setResolvePropertyPlaceholders, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
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)
public boolean isUseGlobalSslContextParameters()
isUseGlobalSslContextParameters
in interface org.apache.camel.SSLContextParametersAware
public void setUseGlobalSslContextParameters(boolean useGlobalSslContextParameters)
setUseGlobalSslContextParameters
in interface org.apache.camel.SSLContextParametersAware
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