org.apache.camel.component.cometd
Class CometdComponent

java.lang.Object
  extended by org.apache.camel.impl.ServiceSupport
      extended by org.apache.camel.impl.DefaultComponent
          extended by org.apache.camel.component.cometd.CometdComponent
All Implemented Interfaces:
CamelContextAware, Component, Service, ShutdownableService

public class CometdComponent
extends DefaultComponent

Component for Jetty Cometd

Version:
$Revision:520964 $

Constructor Summary
CometdComponent()
           
 
Method Summary
 void connect(CometdProducerConsumer prodcon)
          Connects the URL specified on the endpoint to the specified processor.
protected  Endpoint createEndpoint(String uri, String remaining, Map<String,Object> parameters)
          A factory method allowing derived components to create a new endpoint from the given URI, remaining path and optional parameters
protected  org.eclipse.jetty.server.Server createServer()
           
protected  org.cometd.server.continuation.ContinuationCometdServlet createServletForConnector(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()
           
 org.eclipse.jetty.server.Server getServer()
           
 String getSslKeyPassword()
           
 String getSslKeystore()
           
 String getSslPassword()
           
 org.eclipse.jetty.server.ssl.SslSocketConnector getSslSocketConnector()
           
 void setServer(org.eclipse.jetty.server.Server server)
           
 void setSslKeyPassword(String sslKeyPassword)
           
 void setSslKeystore(String sslKeystore)
           
 void setSslPassword(String sslPassword)
           
 
Methods inherited from class org.apache.camel.impl.DefaultComponent
afterConfiguration, createEndpoint, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, ifStartsWithReturnRemainder, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, useIntrospectionOnEndpoint, validateParameters, validateURI
 
Methods inherited from class org.apache.camel.impl.ServiceSupport
addChildService, doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, removeChildService, resume, shutdown, start, start, stop, suspend
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

CometdComponent

public CometdComponent()
Method Detail

createEndpoint

protected Endpoint createEndpoint(String uri,
                                  String remaining,
                                  Map<String,Object> parameters)
                           throws Exception
Description copied from class: DefaultComponent
A factory method allowing derived components to create a new endpoint from the given URI, remaining path and optional parameters

Specified by:
createEndpoint in class DefaultComponent
Parameters:
uri - the full URI of the endpoint
remaining - the remaining part of the URI without the query parameters or component prefix
parameters - the optional parameters passed in
Returns:
a newly created endpoint or null if the endpoint cannot be created based on the inputs
Throws:
Exception

connect

public void connect(CometdProducerConsumer prodcon)
             throws Exception
Connects the URL specified on the endpoint to the specified processor.

Throws:
Exception

disconnect

public void disconnect(CometdProducerConsumer prodcon)
                throws Exception
Disconnects the URL specified on the endpoint from the specified processor.

Throws:
Exception

createServletForConnector

protected org.cometd.server.continuation.ContinuationCometdServlet createServletForConnector(org.eclipse.jetty.server.Connector connector,
                                                                                             CometdEndpoint endpoint)
                                                                                      throws Exception
Throws:
Exception

getSslSocketConnector

public org.eclipse.jetty.server.ssl.SslSocketConnector getSslSocketConnector()

getServer

public org.eclipse.jetty.server.Server getServer()
                                          throws Exception
Throws:
Exception

setServer

public void setServer(org.eclipse.jetty.server.Server server)

getSslKeyPassword

public String getSslKeyPassword()

getSslPassword

public String getSslPassword()

getSslKeystore

public String getSslKeystore()

setSslKeyPassword

public void setSslKeyPassword(String sslKeyPassword)

setSslPassword

public void setSslPassword(String sslPassword)

setSslKeystore

public void setSslKeystore(String sslKeystore)

createServer

protected org.eclipse.jetty.server.Server createServer()
                                                throws Exception
Throws:
Exception

doStop

protected void doStop()
               throws Exception
Overrides:
doStop in class DefaultComponent
Throws:
Exception

doStart

protected void doStart()
                throws Exception
Overrides:
doStart in class DefaultComponent
Throws:
Exception


Apache CAMEL