org.apache.camel.component.cometd
Class CometdEndpoint

java.lang.Object
  extended by org.apache.camel.impl.DefaultEndpoint
      extended by org.apache.camel.component.cometd.CometdEndpoint
All Implemented Interfaces:
CamelContextAware, Endpoint, IsSingleton, Service, HasId

public class CometdEndpoint
extends DefaultEndpoint

Endpoint for Camel Cometd.

Version:
$Revision:520964 $

Constructor Summary
CometdEndpoint(CometdComponent component, String uri, String remaining, Map<String,Object> parameters)
           
 
Method Summary
 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 getBaseResource()
           
 CometdComponent getComponent()
           
 int getInterval()
           
 int getLogLevel()
           
 int getMaxInterval()
           
 int getMultiFrameInterval()
           
 String getPath()
           
 int getPort()
           
 String getProtocol()
           
 int getTimeout()
           
 URI getUri()
           
 boolean isJsonCommented()
           
 boolean isSingleton()
          Whether this class supports being singleton or not.
 void setBaseResource(String baseResource)
           
 void setInterval(int interval)
           
 void setJsonCommented(boolean commented)
           
 void setLogLevel(int logLevel)
           
 void setMaxInterval(int maxInterval)
           
 void setMultiFrameInterval(int multiFrameInterval)
           
 void setTimeout(int timeout)
           
 
Methods inherited from class org.apache.camel.impl.DefaultEndpoint
configureProperties, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getEndpointKey, getEndpointUri, getExchangePattern, getExchangeType, getId, hashCode, isLenientProperties, isSynchronous, sanitizeUri, setCamelContext, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setSynchronous, start, stop, toString
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

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()
Overrides:
getComponent in class DefaultEndpoint

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)

getLogLevel

public int getLogLevel()

setLogLevel

public void setLogLevel(int logLevel)


Apache CAMEL