|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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 |
org.apache.camel.component.direct | 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 |
org.apache.camel.management | Camel management |
org.apache.camel.management.mbean | 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 org.apache.camel.component.direct |
---|
Classes in org.apache.camel.component.direct that implement Consumer | |
---|---|
class |
DirectConsumer
The direct consumer. |
Methods in org.apache.camel.component.direct 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 org.apache.camel.management |
---|
Methods in org.apache.camel.management with parameters of type Consumer | |
---|---|
Object |
DefaultManagementObjectStrategy.getManagedObjectForConsumer(CamelContext context,
Consumer consumer)
|
ObjectName |
DefaultManagementNamingStrategy.getObjectNameForConsumer(CamelContext context,
Consumer consumer)
|
Uses of Consumer in org.apache.camel.management.mbean |
---|
Methods in org.apache.camel.management.mbean that return Consumer | |
---|---|
Consumer |
ManagedConsumer.getConsumer()
|
Constructors in org.apache.camel.management.mbean 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 |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |