Uses of Interface
org.apache.camel.Consumer

Packages that use Consumer

org.apache.camel	The JAXB POJOs for the XML Configuration of the routing rules.
org.apache.camel.component.ahc
org.apache.camel.component.apns
org.apache.camel.component.atom
org.apache.camel.component.aws.s3
org.apache.camel.component.aws.sns
org.apache.camel.component.aws.sqs
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.cache
org.apache.camel.component.cometd
org.apache.camel.component.crypto
org.apache.camel.component.cxf	Defines the CXF Component
org.apache.camel.component.cxf.jaxrs
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.dns
org.apache.camel.component.event	An Event Endpoint for working with Spring ApplicationEvents
org.apache.camel.component.eventadmin
org.apache.camel.component.exec
org.apache.camel.component.feed
org.apache.camel.component.file	The File Component for working with file systems.
org.apache.camel.component.file.remote	Defines the File transport for communicating with Remote Files and FTP
org.apache.camel.component.flatpack	The Flatpack Component for working with fixed width or delimited files
org.apache.camel.component.gae.auth
org.apache.camel.component.gae.login
org.apache.camel.component.gae.mail
org.apache.camel.component.hazelcast
org.apache.camel.component.hazelcast.atomicnumber
org.apache.camel.component.hazelcast.instance
org.apache.camel.component.hazelcast.list
org.apache.camel.component.hazelcast.map
org.apache.camel.component.hazelcast.multimap
org.apache.camel.component.hazelcast.queue
org.apache.camel.component.hazelcast.seda
org.apache.camel.component.hdfs
org.apache.camel.component.http	Defines the HTTP Component
org.apache.camel.component.ibatis
org.apache.camel.component.irc	Defines the IRC Component
org.apache.camel.component.javaspace
org.apache.camel.component.jcr
org.apache.camel.component.jdbc	Defines an JDBC component that can bind to JDBC datasources.
org.apache.camel.component.jetty	Defines the Jetty HTTP Component
org.apache.camel.component.jms	Defines the JMS Component
org.apache.camel.component.jmx
org.apache.camel.component.jpa	Defines the JPA component for polling databases or recording messages in a database.
org.apache.camel.component.jt400
org.apache.camel.component.kestrel
org.apache.camel.component.language	The Language Component to send messages to language endpoints executing the script.
org.apache.camel.component.ldap
org.apache.camel.component.lucene
org.apache.camel.component.mail	Defines the Email Component
org.apache.camel.component.mina
org.apache.camel.component.mock	The Mock Component which is used for testing of routing and mediation rules.
org.apache.camel.component.mybatis
org.apache.camel.component.nagios
org.apache.camel.component.netty
org.apache.camel.component.paxlogging
org.apache.camel.component.printer
org.apache.camel.component.quartz	Defines the Quartz Component
org.apache.camel.component.quickfixj
org.apache.camel.component.restlet
org.apache.camel.component.rmi	Defines an RMI Component that can bind PojoExchanges to the Java Remote Method Protocol (JRMP).
org.apache.camel.component.routebox
org.apache.camel.component.routebox.direct
org.apache.camel.component.routebox.seda
org.apache.camel.component.rss
org.apache.camel.component.seda	The SEDA Component for asynchronous SEDA exchanges on a BlockingQueue within a single CamelContext
org.apache.camel.component.servlet
org.apache.camel.component.sip
org.apache.camel.component.smpp
org.apache.camel.component.snmp
org.apache.camel.component.spring.integration
org.apache.camel.component.spring.ws
org.apache.camel.component.sql	Defines an SQL component that can bind to JDBC datasources and execute SQL queries that are exposed as endpoints.
org.apache.camel.component.stream
org.apache.camel.component.timer	The Timer Component extends the POJO component to provide a simple timer
org.apache.camel.component.xmpp	Defines the XMPP transport for communicating over Jabber
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.ahc

Methods in org.apache.camel.component.ahc that return Consumer

Consumer

AhcEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.apns that implement Consumer

class

ApnsConsumer

Methods in org.apache.camel.component.apns that return Consumer

Consumer

ApnsEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.atom that implement Consumer

class	AtomEntryPollingConsumer Consumer to poll atom feeds and return each entry from the feed step by step.
class	AtomPollingConsumer Consumer to poll atom feeds and return the full feed.

Uses of Consumer in org.apache.camel.component.aws.s3

Classes in org.apache.camel.component.aws.s3 that implement Consumer

class

S3Consumer A Consumer of messages from the Amazon Web Service Simple Storage Service AWS S3

Methods in org.apache.camel.component.aws.s3 that return Consumer

Consumer

S3Endpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.component.aws.sns

Methods in org.apache.camel.component.aws.sns that return Consumer

Consumer

SnsEndpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.component.aws.sqs

Classes in org.apache.camel.component.aws.sqs that implement Consumer

class

SqsConsumer A Consumer of messages from the Amazon Web Service Simple Queue Service AWS SQS

Methods in org.apache.camel.component.aws.sqs that return Consumer

Consumer

SqsEndpoint.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.cache

Classes in org.apache.camel.component.cache that implement Consumer

class

CacheConsumer

Methods in org.apache.camel.component.cache that return Consumer

Consumer

CacheEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.cometd that implement Consumer

class

CometdConsumer A Consumer for receiving messages using Cometd and Bayeux protocol.

Methods in org.apache.camel.component.cometd that return Consumer

Consumer

CometdEndpoint.createConsumer(Processor processor)

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

Methods in org.apache.camel.component.crypto that return Consumer

Consumer

DigitalSignatureEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.cxf that implement Consumer

class

CxfConsumer A Consumer of exchanges for a service in CXF.

Methods in org.apache.camel.component.cxf that return Consumer

Consumer

CxfEndpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.component.cxf.jaxrs

Classes in org.apache.camel.component.cxf.jaxrs that implement Consumer

class

CxfRsConsumer A Consumer of exchanges for a JAXRS service in CXF.

Methods in org.apache.camel.component.cxf.jaxrs that return Consumer

Consumer

CxfRsEndpoint.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.dns

Methods in org.apache.camel.component.dns that return Consumer

Consumer	WikipediaEndpoint.createConsumer(Processor processor)
Consumer	DnsLookupEndpoint.createConsumer(Processor processor)
Consumer	DnsIpEndpoint.createConsumer(Processor processor)
Consumer	DnsDigEndpoint.createConsumer(Processor arg0)

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

Classes in org.apache.camel.component.event that implement Consumer

class

EventConsumer An Event Consumer for working with Spring ApplicationEvents

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

Classes in org.apache.camel.component.eventadmin that implement Consumer

class

EventAdminConsumer

Methods in org.apache.camel.component.eventadmin that return Consumer

Consumer

EventAdminEndpoint.createConsumer(Processor processor)

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

Methods in org.apache.camel.component.exec that return Consumer

Consumer

ExecEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.feed that implement Consumer

class	FeedEntryPollingConsumer Consumer to poll feeds and return each entry from the feed step by step.
class	FeedPollingConsumer Base class for consuming feeds.

Methods in org.apache.camel.component.feed that return Consumer

Consumer

FeedEndpoint.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.file.remote

Classes in org.apache.camel.component.file.remote that implement Consumer

class	FtpConsumer FTP consumer
class	RemoteFileConsumer<T> Base class for remote file consumers.
class	SftpConsumer Secure FTP consumer

Methods in org.apache.camel.component.file.remote with parameters of type Consumer

boolean

RemoteFilePollingConsumerPollStrategy.rollback(Consumer consumer, Endpoint endpoint, int retryCounter, Exception e)

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

Methods in org.apache.camel.component.flatpack that return Consumer

Consumer

FixedLengthEndpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.component.gae.auth

Methods in org.apache.camel.component.gae.auth that return Consumer

Consumer

GAuthEndpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.component.gae.login

Methods in org.apache.camel.component.gae.login that return Consumer

Consumer

GLoginEndpoint.createConsumer(Processor processor) throws UnsupportedOperationException

Uses of Consumer in org.apache.camel.component.gae.mail

Methods in org.apache.camel.component.gae.mail that return Consumer

Consumer

GMailEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.hazelcast that implement Consumer

class

HazelcastDefaultConsumer

Methods in org.apache.camel.component.hazelcast that return Consumer

abstract Consumer

HazelcastDefaultEndpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.component.hazelcast.atomicnumber

Methods in org.apache.camel.component.hazelcast.atomicnumber that return Consumer

Consumer

HazelcastAtomicnumberEndpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.component.hazelcast.instance

Classes in org.apache.camel.component.hazelcast.instance that implement Consumer

class

HazelcastInstanceConsumer

Methods in org.apache.camel.component.hazelcast.instance that return Consumer

Consumer

HazelcastInstanceEndpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.component.hazelcast.list

Classes in org.apache.camel.component.hazelcast.list that implement Consumer

class

HazelcastListConsumer Implementation of Hazelcast List Consumer.

Methods in org.apache.camel.component.hazelcast.list that return Consumer

Consumer

HazelcastListEndpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.component.hazelcast.map

Classes in org.apache.camel.component.hazelcast.map that implement Consumer

class

HazelcastMapConsumer

Methods in org.apache.camel.component.hazelcast.map that return Consumer

Consumer

HazelcastMapEndpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.component.hazelcast.multimap

Classes in org.apache.camel.component.hazelcast.multimap that implement Consumer

class

HazelcastMultimapConsumer

Methods in org.apache.camel.component.hazelcast.multimap that return Consumer

Consumer

HazelcastMultimapEndpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.component.hazelcast.queue

Classes in org.apache.camel.component.hazelcast.queue that implement Consumer

class

HazelcastQueueConsumer

Methods in org.apache.camel.component.hazelcast.queue that return Consumer

Consumer

HazelcastQueueEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.hazelcast.seda that implement Consumer

class

HazelcastSedaConsumer Implementation of Hazelcast SEDA Consumer component.

Methods in org.apache.camel.component.hazelcast.seda that return Consumer

Consumer

HazelcastSedaEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.hdfs that implement Consumer

class

HdfsConsumer

Methods in org.apache.camel.component.hdfs that return Consumer

Consumer

HdfsEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.http that implement Consumer

class	HttpConsumer
class	HttpPollingConsumer A polling HTTP consumer which by default performs a GET

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

Classes in org.apache.camel.component.ibatis that implement Consumer

class

IBatisConsumer Consumer to read data from databaase.

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

Classes in org.apache.camel.component.irc that implement Consumer

class

IrcConsumer

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

Classes in org.apache.camel.component.javaspace that implement Consumer

class

JavaSpaceConsumer

Methods in org.apache.camel.component.javaspace that return Consumer

Consumer

JavaSpaceEndpoint.createConsumer(Processor processor)

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

Methods in org.apache.camel.component.jcr that return Consumer

Consumer

JcrEndpoint.createConsumer(Processor processor) Currently unsupported

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

Methods in org.apache.camel.component.jdbc that return Consumer

Consumer

JdbcEndpoint.createConsumer(Processor processor)

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

Methods in org.apache.camel.component.jetty that return Consumer

Consumer

JettyHttpEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.jms that implement Consumer

class	JmsConsumer A Consumer which uses Spring's DefaultMessageListenerContainer implementations to consume JMS messages
class	JmsPollingConsumer

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

Classes in org.apache.camel.component.jmx that implement Consumer

class	JMXConsumer Consumer will add itself as a NotificationListener on the object specified by the objectName param.
class	JMXMonitorConsumer Variant of the consumer that creates and registers a monitor bean to monitor object and attribute referenced by the endpoint.

Methods in org.apache.camel.component.jmx that return Consumer

Consumer

JMXEndpoint.createConsumer(Processor aProcessor)

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

Classes in org.apache.camel.component.jpa that implement Consumer

class

JpaConsumer

Methods in org.apache.camel.component.jpa that return Consumer

Consumer

JpaEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.jt400 that implement Consumer

class

Jt400DataQueueConsumer PollingConsumer that polls a data queue for data

Methods in org.apache.camel.component.jt400 that return Consumer

Consumer

Jt400PgmEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.kestrel that implement Consumer

class

KestrelConsumer A Camel consumer that polls a kestrel queue.

Methods in org.apache.camel.component.kestrel that return Consumer

Consumer

KestrelEndpoint.createConsumer(Processor processor)

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.ldap

Methods in org.apache.camel.component.ldap that return Consumer

Consumer

LdapEndpoint.createConsumer(Processor processor)

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

Methods in org.apache.camel.component.lucene that return Consumer

Consumer

LuceneEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.mail that implement Consumer

class

MailConsumer A Consumer which consumes messages from JavaMail using a Transport and dispatches them to the Processor

Methods in org.apache.camel.component.mail that return Consumer

Consumer	MailEndpoint.createConsumer(Processor processor)
Consumer	MailEndpoint.createConsumer(Processor processor, org.springframework.mail.javamail.JavaMailSenderImpl sender) Creates a consumer using the given processor and sender

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

Classes in org.apache.camel.component.mina that implement Consumer

class

MinaConsumer A Consumer implementation for Apache MINA.

Methods in org.apache.camel.component.mina that return Consumer

Consumer

MinaEndpoint.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.mybatis

Classes in org.apache.camel.component.mybatis that implement Consumer

class

MyBatisConsumer Consumer to read data from a database.

Methods in org.apache.camel.component.mybatis that return Consumer

Consumer

MyBatisEndpoint.createConsumer(Processor processor)

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

Methods in org.apache.camel.component.nagios that return Consumer

Consumer

NagiosEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.netty that implement Consumer

class

NettyConsumer

Methods in org.apache.camel.component.netty that return Consumer

Consumer

NettyEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.paxlogging that implement Consumer

class

PaxLoggingConsumer Paxlogging consumer.

Methods in org.apache.camel.component.paxlogging that return Consumer

Consumer

PaxLoggingEndpoint.createConsumer(Processor processor)

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

Methods in org.apache.camel.component.printer that return Consumer

Consumer

PrinterEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.quartz that implement Consumer

class

QuartzConsumer

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

Classes in org.apache.camel.component.quickfixj that implement Consumer

class

QuickfixjConsumer

Methods in org.apache.camel.component.quickfixj that return Consumer

Consumer

QuickfixjEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.restlet that implement Consumer

class

RestletConsumer A Restlet consumer acts as a server to listen client requests.

Methods in org.apache.camel.component.restlet that return Consumer

Consumer

RestletEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.rmi that implement Consumer

class

RmiConsumer A Consumer which uses RMI's UnicastRemoteObject to consume method invocations.

Methods in org.apache.camel.component.rmi that return Consumer

Consumer

RmiEndpoint.createConsumer(Processor processor)

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

Subinterfaces of Consumer in org.apache.camel.component.routebox

interface

RouteboxConsumer

Uses of Consumer in org.apache.camel.component.routebox.direct

Classes in org.apache.camel.component.routebox.direct that implement Consumer

class

RouteboxDirectConsumer

Methods in org.apache.camel.component.routebox.direct that return Consumer

Consumer

RouteboxDirectEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.routebox.seda that implement Consumer

class

RouteboxSedaConsumer

Methods in org.apache.camel.component.routebox.seda that return Consumer

Consumer

RouteboxSedaEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.rss that implement Consumer

class	RssEntryPollingConsumer Consumer to poll RSS feeds and return each entry from the feed step by step.
class	RssPollingConsumer Consumer to poll RSS feeds and return the full feed.

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.

Methods in org.apache.camel.component.seda that return Consumer

Consumer

SedaEndpoint.createConsumer(Processor processor)

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

Methods in org.apache.camel.component.servlet that return Consumer

Consumer

ServletEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.sip that implement Consumer

class	SipPresenceAgent
class	SipSubscriber

Methods in org.apache.camel.component.sip that return Consumer

Consumer

SipEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.smpp that implement Consumer

class

SmppConsumer An implementation of @{link Consumer} which use the SMPP protocol

Methods in org.apache.camel.component.smpp that return Consumer

Consumer

SmppEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.snmp that implement Consumer

class	SnmpOIDPoller
class	SnmpTrapConsumer

Methods in org.apache.camel.component.snmp that return Consumer

Consumer

SnmpEndpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.component.spring.integration

Classes in org.apache.camel.component.spring.integration that implement Consumer

class

SpringIntegrationConsumer A consumer of exchanges for the Spring Integration Please specify the inputChannel in the endpoint url for this consumer.

Methods in org.apache.camel.component.spring.integration that return Consumer

Consumer

SpringIntegrationEndpoint.createConsumer(Processor processor)

Uses of Consumer in org.apache.camel.component.spring.ws

Classes in org.apache.camel.component.spring.ws that implement Consumer

class

SpringWebserviceConsumer

Methods in org.apache.camel.component.spring.ws that return Consumer

Consumer

SpringWebserviceEndpoint.createConsumer(Processor processor)

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

Methods in org.apache.camel.component.sql that return Consumer

Consumer

SqlEndpoint.createConsumer(Processor processor)

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

Classes in org.apache.camel.component.stream that implement Consumer

class

StreamConsumer Consumer that can read from streams

Methods in org.apache.camel.component.stream that return Consumer

Consumer

StreamEndpoint.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.component.xmpp

Classes in org.apache.camel.component.xmpp that implement Consumer

class

XmppConsumer A Consumer which listens to XMPP packets

Methods in org.apache.camel.component.xmpp that return Consumer

Consumer

XmppEndpoint.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	ScheduledPollConsumer A useful base class for any consumer which is polling based

Methods in org.apache.camel.impl that return Consumer

Consumer	InterceptSendToEndpoint.createConsumer(Processor processor)
Consumer	DefaultPollingEndpoint.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	LimitedPollingConsumerPollStrategy.commit(Consumer consumer, Endpoint endpoint, int polledMessages)
void	DefaultPollingConsumerPollStrategy.commit(Consumer consumer, Endpoint endpoint, int polledMessages)
protected void	ScheduledPollEndpoint.configureConsumer(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	LimitedPollingConsumerPollStrategy.rollback(Consumer consumer, Endpoint endpoint, int retryCounter, Exception cause)
boolean	DefaultPollingConsumerPollStrategy.rollback(Consumer consumer, Endpoint endpoint, int retryCounter, Exception e)
protected void	DefaultShutdownStrategy.shutdownNow(Consumer consumer) Shutdown the consumer immediately.
protected boolean	RoutePolicySupport.startConsumer(Consumer consumer)
protected boolean	RoutePolicySupport.stopConsumer(Consumer consumer)
protected 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)
boolean	PollingConsumerPollStrategy.rollback(Consumer consumer, Endpoint endpoint, int retryCounter, Exception cause) Called when poll failed