Uses of Interface

Packages that use Consumer
org.apache.camel The core Camel API. 
org.apache.camel.component.binding The Binding Component which is a way of wrapping an Endpoint in a contract; such as a Data Format, a Content Enricher or validation step. 
org.apache.camel.component.browse The Browse Component which is a simple in memory component which maintains a list of all message exchanges which can be useful for debugging, tooling or visualistion. 
org.apache.camel.component.controlbus The Control Bus Component which allows to manage Camel at runtime. 
org.apache.camel.component.dataformat The DataFormat Component allows to use Data Format as a Camel Component. 
org.apache.camel.component.dataset A DataSet Endpoint for testing of endpoints using defined DataSets The Direct Component which synchronously invokes all the consumers when a producer sends an exchange to the endpoint. 
org.apache.camel.component.directvm The Direct VM Component which synchronously invokes the consumer when a producer sends an exchange to the endpoint. 
org.apache.camel.component.file The File Component for working with file systems. 
org.apache.camel.component.language The Language Component to send messages to language endpoints executing the script. 
org.apache.camel.component.mock The Mock Component which is used for testing of routing and mediation rules. 
org.apache.camel.component.seda The SEDA Component for asynchronous SEDA exchanges on a BlockingQueue within a single CamelContext 
org.apache.camel.component.timer The Timer Component extends the POJO component to provide a simple timer 
org.apache.camel.impl Default implementation classes for Camel Core Camel management Camel management JMX MBeans 
org.apache.camel.processor.loadbalancer Various load balancer processors 
org.apache.camel.spi Service Provider Interfaces used internally by the Camel runtime which are plugin strategies. 

Uses of Consumer in org.apache.camel

Subinterfaces of Consumer in org.apache.camel
 interface BatchConsumer
          A consumer of a batch of message exchanges from an Endpoint
 interface PollingConsumer
          Represents a Polling Consumer where the caller polls for messages when it is ready.

Methods in org.apache.camel that return Consumer
 Consumer Endpoint.createConsumer(Processor processor)
          Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor
 Consumer Route.getConsumer()
          Gets the inbound Consumer

Uses of Consumer in org.apache.camel.component.binding

Methods in org.apache.camel.component.binding that return Consumer
 Consumer BindingEndpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.component.browse

Methods in org.apache.camel.component.browse that return Consumer
 Consumer BrowseEndpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.component.controlbus

Methods in org.apache.camel.component.controlbus that return Consumer
 Consumer ControlBusEndpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.component.dataformat

Methods in org.apache.camel.component.dataformat that return Consumer
 Consumer DataFormatEndpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.component.dataset

Classes in org.apache.camel.component.dataset that implement Consumer
 class DataSetConsumer
          DataSet consumer.

Methods in org.apache.camel.component.dataset that return Consumer
 Consumer DataSetEndpoint.createConsumer(Processor processor)

Uses of Consumer in

Classes in that implement Consumer
 class DirectConsumer
          The direct consumer.

Methods in that return Consumer
 Consumer DirectEndpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.component.directvm

Classes in org.apache.camel.component.directvm that implement Consumer
 class DirectVmConsumer
          The direct-vm consumer

Methods in org.apache.camel.component.directvm that return Consumer
 Consumer DirectVmEndpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.component.file

Classes in org.apache.camel.component.file that implement Consumer
 class FileConsumer
          File consumer.
 class GenericFileConsumer<T>
          Base class for file consumers.

Uses of Consumer in org.apache.camel.component.language

Methods in org.apache.camel.component.language that return Consumer
 Consumer LanguageEndpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.component.mock

Methods in org.apache.camel.component.mock that return Consumer
 Consumer MockEndpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.component.seda

Classes in org.apache.camel.component.seda that implement Consumer
 class SedaConsumer
          A Consumer for the SEDA component.
 class SedaPollingConsumer

Methods in org.apache.camel.component.seda that return Consumer
 Consumer SedaEndpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.component.timer

Classes in org.apache.camel.component.timer that implement Consumer
 class TimerConsumer
          The timer consumer.

Methods in org.apache.camel.component.timer that return Consumer
 Consumer TimerEndpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.impl

Classes in org.apache.camel.impl that implement Consumer
 class DefaultConsumer
          A default consumer useful for implementation inheritance.
 class DefaultScheduledPollConsumer
          A default implementation of an event driven Consumer which uses the PollingConsumer
 class EventDrivenPollingConsumer
          A default implementation of the PollingConsumer which uses the normal asynchronous consumer mechanism along with a BlockingQueue to allow the caller to pull messages on demand.
 class PollingConsumerSupport
          A useful base class for implementations of PollingConsumer
 class ProcessorPollingConsumer
          A simple implementation of PollingConsumer which just uses a Processor.
 class ScheduledBatchPollingConsumer
          A useful base class for any consumer which is polling batch based
 class ScheduledPollConsumer
          A useful base class for any consumer which is polling based

Methods in org.apache.camel.impl that return Consumer
 Consumer DefaultPollingEndpoint.createConsumer(Processor processor)
 Consumer InterceptSendToEndpoint.createConsumer(Processor processor)
 Consumer EventDrivenConsumerRoute.getConsumer()

Methods in org.apache.camel.impl that return types with arguments of type Consumer
 Map<Route,Consumer> RouteService.getInputs()
          Gets the inputs to the routes.
 List<Consumer> DefaultRouteStartupOrder.getInputs()

Methods in org.apache.camel.impl with parameters of type Consumer
 boolean DefaultPollingConsumerPollStrategy.begin(Consumer consumer, Endpoint endpoint)
 void DefaultPollingConsumerPollStrategy.commit(Consumer consumer, Endpoint endpoint, int polledMessages)
 void LimitedPollingConsumerPollStrategy.commit(Consumer consumer, Endpoint endpoint, int polledMessages)
protected  void DefaultEndpoint.configureConsumer(Consumer consumer)
 void DefaultScheduledPollConsumerScheduler.onInit(Consumer consumer)
protected  boolean LimitedPollingConsumerPollStrategy.onRollback(Consumer consumer, Endpoint endpoint)
          Rollback occurred.
protected  void LimitedPollingConsumerPollStrategy.onSuspend(Consumer consumer, Endpoint endpoint)
          The consumer is to be suspended because it exceeded the limit
 boolean DefaultPollingConsumerPollStrategy.rollback(Consumer consumer, Endpoint endpoint, int retryCounter, Exception e)
 boolean LimitedPollingConsumerPollStrategy.rollback(Consumer consumer, Endpoint endpoint, int retryCounter, Exception cause)
protected static void DefaultShutdownStrategy.shutdownNow(Consumer consumer)
          Shutdown the consumer immediately.
protected  boolean RoutePolicySupport.startConsumer(Consumer consumer)
protected  boolean RoutePolicySupport.stopConsumer(Consumer consumer)
protected static void DefaultShutdownStrategy.suspendNow(Consumer consumer)
          Suspends/stops the consumer immediately.

Method parameters in org.apache.camel.impl with type arguments of type Consumer
protected  void DefaultShutdownStrategy.shutdownNow(List<Consumer> consumers)
          Shutdown all the consumers immediately.

Uses of Consumer in

Methods in with parameters of type Consumer
 Object DefaultManagementObjectStrategy.getManagedObjectForConsumer(CamelContext context, Consumer consumer)
 ObjectName DefaultManagementNamingStrategy.getObjectNameForConsumer(CamelContext context, Consumer consumer)

Uses of Consumer in

Methods in that return Consumer
 Consumer ManagedConsumer.getConsumer()

Constructors in with parameters of type Consumer
ManagedConsumer(CamelContext context, Consumer consumer)

Uses of Consumer in org.apache.camel.processor.loadbalancer

Classes in org.apache.camel.processor.loadbalancer that implement Consumer
 class LoadBalancerConsumer
          Represents a consumer which on starting registers itself with a LoadBalancer and on closing unregisters itself with a load balancer

Uses of Consumer in org.apache.camel.spi

Methods in org.apache.camel.spi that return types with arguments of type Consumer
 List<Consumer> RouteStartupOrder.getInputs()
          Gets the input to this route (often only one consumer)

Methods in org.apache.camel.spi with parameters of type Consumer
 boolean PollingConsumerPollStrategy.begin(Consumer consumer, Endpoint endpoint)
          Called when poll is about to begin
 void PollingConsumerPollStrategy.commit(Consumer consumer, Endpoint endpoint, int polledMessages)
          Called when poll is completed successfully
 Object ManagementObjectStrategy.getManagedObjectForConsumer(CamelContext context, Consumer consumer)
 ObjectName ManagementNamingStrategy.getObjectNameForConsumer(CamelContext context, Consumer consumer)
 void ScheduledPollConsumerScheduler.onInit(Consumer consumer)
          Initializes this ScheduledPollConsumerScheduler with the associated Consumer.
 boolean PollingConsumerPollStrategy.rollback(Consumer consumer, Endpoint endpoint, int retryCounter, Exception cause)
          Called when poll failed

Apache Camel