Uses of Interface
org.apache.camel.Consumer

Packages that use Consumer

Package	Description
org.apache.camel	The core Camel API.
org.apache.camel.spi

Uses of Consumer in org.apache.camel

Subinterfaces of Consumer in org.apache.camel

Modifier and Type	Interface	Description
interface	BatchConsumer	A Consumer that receives messages from an Endpoint in discrete batches rather than one at a time.
interface	DynamicPollingConsumer	A PollingConsumer used by the dynamic poll and pollEnrich EIPs, allowing the component to use data from the current Exchange (such as headers or properties) to parameterise the poll operation at runtime.
interface	PollingConsumer	Represents a Polling Consumer where the caller polls for messages when it is ready.

Methods in org.apache.camel that return Consumer

Modifier and Type	Method	Description
Consumer	Endpoint.createConsumer(Processor processor)	Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor Important: Do not do any initialization in the constructor of the Consumer.
Consumer	Route.getConsumer()	Gets the inbound Consumer

Uses of Consumer in org.apache.camel.spi

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

Modifier and Type	Method	Description
Consumer	RestApiConsumerFactory.createApiConsumer(CamelContext camelContext, Processor processor, String contextPath, RestConfiguration configuration, Map<String,Object> parameters)	Creates a new REST API Event Driven Consumer, which provides API listing of the REST services
Consumer	RestConsumerFactory.createConsumer(CamelContext camelContext, Processor processor, String verb, String basePath, @Nullable String uriTemplate, @Nullable String consumes, @Nullable String produces, RestConfiguration configuration, Map<String,Object> parameters)	Creates a new REST Event Driven Consumer, which consumes messages from the endpoint using the given processor
Consumer	RestOpenApiConsumerFactory.createConsumer(CamelContext camelContext, Processor processor, String contextPath, RestConfiguration configuration, Map<String,Object> parameters)	Creates a new REST Event Driven Consumer, which consumes messages from the endpoint using the given processor
@Nullable Consumer	ExchangeFactory.getConsumer()	The consumer using this factory.
Consumer	RestRegistry.RestService.getConsumer()	Gets the consumer of the REST service
Consumer	RouteStartupOrder.getInput()	Gets the input to this route

Methods in org.apache.camel.spi with parameters of type Consumer

Modifier and Type	Method	Description
void	RestRegistry.addRestService(Consumer consumer, boolean contractFirst, String url, String baseUrl, String basePath, @Nullable String uriTemplate, String method, @Nullable String consumes, @Nullable String produces, @Nullable String inType, @Nullable String outType, String routeId, @Nullable String operationId, @Nullable String specificationUri, @Nullable String description)	Adds a new REST service to the registry.
void	RestRegistry.addRestSpecification(Consumer consumer, boolean contractFirst, String url, String baseUrl, String basePath, String method, @Nullable String produces, @Nullable String description)	Adds information about the API specification (ie api-doc)
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	ManagementObjectNameStrategy.getObjectNameForConsumer(CamelContext context, Consumer consumer)
ExchangeFactory	ExchangeFactory.newExchangeFactory(Consumer consumer)	Creates a new ExchangeFactory that is private for the given consumer.
void	ScheduledPollConsumerScheduler.onInit(Consumer consumer)	Initializes this ScheduledPollConsumerScheduler with the associated Consumer.
void	RestRegistry.removeRestService(Consumer consumer)	Removes the REST service from the registry
boolean	PollingConsumerPollStrategy.rollback(Consumer consumer, Endpoint endpoint, int retryCounter, Exception cause)	Called when poll failed