@UriEndpoint(scheme="cometd,cometds", title="CometD", syntax="cometd:host:port/channelName", consumerClass=CometdConsumer.class, label="websocket") public class CometdEndpoint extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
CometdEndpoint(CometdComponent component,
String uri,
String remaining,
Map<String,Object> parameters) |
Modifier and Type | Method and Description |
---|---|
void |
connect(CometdProducerConsumer prodcons) |
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
void |
disconnect(CometdProducerConsumer prodcons) |
String |
getAllowedOrigins() |
String |
getBaseResource() |
CometdComponent |
getComponent() |
String |
getFilterPath() |
int |
getInterval() |
int |
getLogLevel() |
int |
getMaxInterval() |
int |
getMultiFrameInterval() |
String |
getPath() |
int |
getPort() |
String |
getProtocol() |
int |
getTimeout() |
URI |
getUri() |
boolean |
isCrossOriginFilterOn() |
boolean |
isDisconnectLocalSession() |
boolean |
isJsonCommented() |
boolean |
isSessionHeadersEnabled() |
boolean |
isSingleton() |
void |
setAllowedOrigins(String allowedOrigins)
The origins domain that support to cross, if the crosssOriginFilterOn is true
|
void |
setBaseResource(String baseResource)
The root directory for the web resources or classpath.
|
void |
setCrossOriginFilterOn(boolean crossOriginFilterOn)
If true, the server will support for cross-domain filtering
|
void |
setDisconnectLocalSession(boolean disconnectLocalSession)
Whether to disconnect local sessions after publishing a message to its channel.
|
void |
setFilterPath(String filterPath)
The filterPath will be used by the CrossOriginFilter, if the crosssOriginFilterOn is true
|
void |
setInterval(int interval)
The client side poll timeout in milliseconds.
|
void |
setJsonCommented(boolean commented)
If true, the server will accept JSON wrapped in a comment and will generate JSON wrapped in a comment.
|
void |
setLogLevel(int logLevel)
Logging level.
|
void |
setMaxInterval(int maxInterval)
The max client side poll timeout in milliseconds.
|
void |
setMultiFrameInterval(int multiFrameInterval)
The client side poll timeout, if multiple connections are detected from the same browser.
|
void |
setSessionHeadersEnabled(boolean enable)
Whether to include the server session headers in the Camel message when creating a Camel Message for incoming requests.
|
void |
setTimeout(int timeout)
The server side poll timeout in milliseconds.
|
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public void connect(CometdProducerConsumer prodcons) throws Exception
Exception
public void disconnect(CometdProducerConsumer prodcons) throws Exception
Exception
public CometdComponent getComponent()
getComponent
in class org.apache.camel.impl.DefaultEndpoint
public boolean isSingleton()
public String getPath()
public int getPort()
public String getProtocol()
public URI getUri()
public String getBaseResource()
public void setBaseResource(String baseResource)
public int getTimeout()
public void setTimeout(int timeout)
public int getInterval()
public void setInterval(int interval)
public int getMaxInterval()
public void setMaxInterval(int maxInterval)
public int getMultiFrameInterval()
public void setMultiFrameInterval(int multiFrameInterval)
public boolean isJsonCommented()
public void setJsonCommented(boolean commented)
public void setSessionHeadersEnabled(boolean enable)
public boolean isSessionHeadersEnabled()
public int getLogLevel()
public void setLogLevel(int logLevel)
public String getAllowedOrigins()
public void setAllowedOrigins(String allowedOrigins)
public boolean isCrossOriginFilterOn()
public void setCrossOriginFilterOn(boolean crossOriginFilterOn)
public String getFilterPath()
public void setFilterPath(String filterPath)
public boolean isDisconnectLocalSession()
public void setDisconnectLocalSession(boolean disconnectLocalSession)
Apache Camel