org.apache.camel.component.cometd

Class CometdEndpoint

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.impl.DefaultEndpoint

org.apache.camel.component.cometd.CometdEndpoint

All Implemented Interfaces:

CamelContextAware, Endpoint, IsSingleton, Service, ShutdownableService, HasId, StatefulService, SuspendableService

@UriEndpoint(scheme="cometd,cometds",
             title="CometD",
             syntax="cometd:protocol:host:port/channelName",
             consumerClass=CometdConsumer.class,
             label="http,websocket")
public class CometdEndpoint
extends DefaultEndpoint

Endpoint for Camel Cometd.

Field Summary

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

Constructors

Constructor and Description
CometdEndpoint(CometdComponent component, String uri, String remaining, Map<String,Object> parameters)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	areSessionHeadersEnabled()
void	connect(CometdProducerConsumer prodcons)
Consumer	createConsumer(Processor processor) Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor
Producer	createProducer() Creates a new producer which is used send messages into the endpoint
void	disconnect(CometdProducerConsumer prodcons)
String	getAllowedOrigins()
String	getBaseResource()
CometdComponent	getComponent() Returns the component that created this endpoint.
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	isSingleton() Whether this class supports being singleton or not.
void	setAllowedOrigins(String allowedOrigins)
void	setBaseResource(String baseResource)
void	setCrossOriginFilterOn(boolean crossOriginFilterOn)
void	setDisconnectLocalSession(boolean disconnectLocalSession)
void	setFilterPath(String filterPath)
void	setInterval(int interval)
void	setJsonCommented(boolean commented)
void	setLogLevel(int logLevel)
void	setMaxInterval(int maxInterval)
void	setMultiFrameInterval(int multiFrameInterval)
void	setSessionHeadersEnabled(boolean enable)
void	setTimeout(int timeout)

Methods inherited from class org.apache.camel.impl.DefaultEndpoint

configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, getPollingConsumerQueueSize, hashCode, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.camel.Service

start, stop

Constructor Detail

CometdEndpoint

public CometdEndpoint(CometdComponent component,
              String uri,
              String remaining,
              Map<String,Object> parameters)

Method Detail

createProducer

public Producer createProducer()
                        throws Exception

Description copied from interface: Endpoint

Creates a new producer which is used send messages into the endpoint

Returns:

a newly created producer

Throws:

Exception - can be thrown

createConsumer

public Consumer createConsumer(Processor processor)
                        throws Exception

Description copied from interface: Endpoint

Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor

Parameters:

processor - the given processor

Returns:

a newly created consumer

Throws:

Exception - can be thrown

connect

public void connect(CometdProducerConsumer prodcons)
             throws Exception

Throws:

Exception

disconnect

public void disconnect(CometdProducerConsumer prodcons)
                throws Exception

Throws:

Exception

getComponent

public CometdComponent getComponent()

Description copied from class: DefaultEndpoint

Returns the component that created this endpoint.

Overrides:

getComponent in class DefaultEndpoint

Returns:

the component that created this endpoint, or null if none set

isSingleton

public boolean isSingleton()

Description copied from interface: IsSingleton

Whether this class supports being singleton or not.

Returns:

true to be a single shared instance, false to create new instances.

getPath

public String getPath()

getPort

public int getPort()

getProtocol

public String getProtocol()

getUri

public URI getUri()

getBaseResource

public String getBaseResource()

setBaseResource

public void setBaseResource(String baseResource)

getTimeout

public int getTimeout()

setTimeout

public void setTimeout(int timeout)

getInterval

public int getInterval()

setInterval

public void setInterval(int interval)

getMaxInterval

public int getMaxInterval()

setMaxInterval

public void setMaxInterval(int maxInterval)

getMultiFrameInterval

public int getMultiFrameInterval()

setMultiFrameInterval

public void setMultiFrameInterval(int multiFrameInterval)

isJsonCommented

public boolean isJsonCommented()

setJsonCommented

public void setJsonCommented(boolean commented)

setSessionHeadersEnabled

public void setSessionHeadersEnabled(boolean enable)

areSessionHeadersEnabled

public boolean areSessionHeadersEnabled()

getLogLevel

public int getLogLevel()

setLogLevel

public void setLogLevel(int logLevel)

getAllowedOrigins

public String getAllowedOrigins()

setAllowedOrigins

public void setAllowedOrigins(String allowedOrigins)

isCrossOriginFilterOn

public boolean isCrossOriginFilterOn()

setCrossOriginFilterOn

public void setCrossOriginFilterOn(boolean crossOriginFilterOn)

getFilterPath

public String getFilterPath()

setFilterPath

public void setFilterPath(String filterPath)

isDisconnectLocalSession

public boolean isDisconnectLocalSession()

setDisconnectLocalSession

public void setDisconnectLocalSession(boolean disconnectLocalSession)