org.apache.camel.impl

Class EventDrivenConsumerRoute

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.impl.DefaultRoute

org.apache.camel.impl.EventDrivenConsumerRoute

All Implemented Interfaces:

EndpointAware, Route, Service, ShutdownableService, StatefulService, SuspendableService

public class EventDrivenConsumerRoute
extends DefaultRoute

A DefaultRoute which starts with an Event Driven Consumer

Use the API from CamelContext to control the lifecycle of a route, such as starting and stopping using the CamelContext.startRoute(String) and CamelContext.stopRoute(String) methods.

Version:

Field Summary

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

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

Fields inherited from interface org.apache.camel.Route

DESCRIPTION_PROPERTY, GROUP_PROPERTY, ID_PROPERTY, PARENT_PROPERTY, REST_PROPERTY

Constructor Summary

Constructors

Constructor and Description
EventDrivenConsumerRoute(RouteContext routeContext, Endpoint endpoint, Processor processor)

Method Summary

Modifier and Type	Method and Description
protected void	addServices(List<Service> services) Factory method to lazily create the complete list of services required for this route such as adding the processor or consumer
List<Processor>	filter(String pattern) Returns a list of all the Processors from this route that has id's matching the pattern
Consumer	getConsumer() Gets the inbound Consumer
Processor	getProcessor()
Navigate<Processor>	navigate() Returns a navigator to navigate this route by navigating all the Processors.
boolean	supportsSuspension() Whether or not the route supports suspension (suspend and resume)
String	toString()

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

addService, doShutdown, doStart, doStop, getDescription, getEndpoint, getId, getProperties, getRouteContext, getServices, getUptime, getUptimeMillis, onStartingServices, start, stop, warmUp

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

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

EventDrivenConsumerRoute

public EventDrivenConsumerRoute(RouteContext routeContext,
                                Endpoint endpoint,
                                Processor processor)

Method Detail

toString

public String toString()

Overrides:

toString in class DefaultRoute

getProcessor

public Processor getProcessor()

addServices

protected void addServices(List<Service> services)
                    throws Exception

Factory method to lazily create the complete list of services required for this route such as adding the processor or consumer

Overrides:

addServices in class DefaultRoute

Throws:

Exception

navigate

public Navigate<Processor> navigate()

Description copied from interface: Route

Returns a navigator to navigate this route by navigating all the Processors.

Returns:

a navigator for Processor.

filter

public List<Processor> filter(String pattern)

Description copied from interface: Route

Returns a list of all the Processors from this route that has id's matching the pattern

Parameters:

pattern - the pattern to match by ids

Returns:

a list of Processor, is never null.

getConsumer

public Consumer getConsumer()

Description copied from interface: Route

Gets the inbound Consumer

Returns:

the inbound consumer

supportsSuspension

public boolean supportsSuspension()

Description copied from interface: Route

Whether or not the route supports suspension (suspend and resume)

Returns:

true if this route supports suspension