| Package | Description |
|---|---|
| org.apache.camel |
The core Camel API.
|
| org.apache.camel.component.file |
The File Component for working with file systems.
|
| org.apache.camel.component.seda | |
| org.apache.camel.impl |
Default implementation classes for Camel Core
|
| Modifier and Type | Method and Description |
|---|---|
PollingConsumer |
Endpoint.createPollingConsumer()
Creates a new Polling
Consumer so that the caller can poll message exchanges from the
consumer using
receive(),
receiveNoWait() or
receive(long) whenever it is ready to do so
rather than using the Event
Based Consumer returned by Endpoint.createConsumer(Processor) |
| Modifier and Type | Method and Description |
|---|---|
ServicePool<Endpoint,PollingConsumer> |
CamelContext.getPollingConsumerServicePool()
Gets the service pool for
Producer pooling. |
| Modifier and Type | Method and Description |
|---|---|
void |
CamelContext.setPollingConsumerServicePool(ServicePool<Endpoint,PollingConsumer> servicePool)
Sets a pluggable service pool to use for
PollingConsumer pooling. |
| Modifier and Type | Class and Description |
|---|---|
class |
GenericFilePollingConsumer |
| Modifier and Type | Method and Description |
|---|---|
PollingConsumer |
FileEndpoint.createPollingConsumer() |
| Modifier and Type | Class and Description |
|---|---|
class |
SedaPollingConsumer |
| Modifier and Type | Method and Description |
|---|---|
PollingConsumer |
SedaEndpoint.createPollingConsumer() |
| Modifier and Type | Class and Description |
|---|---|
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. |
| Modifier and Type | Method and Description |
|---|---|
PollingConsumer |
EmptyConsumerCache.acquirePollingConsumer(Endpoint endpoint) |
PollingConsumer |
ConsumerCache.acquirePollingConsumer(Endpoint endpoint)
Acquires a pooled PollingConsumer which you must release back again after usage using the
ConsumerCache.releasePollingConsumer(org.apache.camel.Endpoint, org.apache.camel.PollingConsumer) method. |
protected PollingConsumer |
CamelPostProcessorHelper.createInjectionPollingConsumer(Endpoint endpoint,
Object bean,
String beanName)
Factory method to create a started
PollingConsumer to be injected into a POJO |
PollingConsumer |
ProcessorEndpoint.createPollingConsumer() |
PollingConsumer |
InterceptSendToEndpoint.createPollingConsumer() |
PollingConsumer |
DefaultEndpoint.createPollingConsumer() |
protected PollingConsumer |
ConsumerCache.doGetPollingConsumer(Endpoint endpoint,
boolean pooled) |
PollingConsumer |
ConsumerCache.getConsumer(Endpoint endpoint) |
| Modifier and Type | Method and Description |
|---|---|
protected static Map<String,PollingConsumer> |
ConsumerCache.createLRUCache(int cacheSize)
Creates the
LRUCache to be used. |
protected ServicePool<Endpoint,PollingConsumer> |
DefaultCamelContext.createPollingConsumerServicePool() |
ServicePool<Endpoint,PollingConsumer> |
DefaultCamelContext.getPollingConsumerServicePool() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
ScheduledPollEndpoint.configurePollingConsumer(PollingConsumer consumer) |
protected void |
DefaultEndpoint.configurePollingConsumer(PollingConsumer consumer) |
void |
EmptyConsumerCache.releasePollingConsumer(Endpoint endpoint,
PollingConsumer pollingConsumer) |
void |
ConsumerCache.releasePollingConsumer(Endpoint endpoint,
PollingConsumer pollingConsumer)
Releases an acquired producer back after usage.
|
| Modifier and Type | Method and Description |
|---|---|
void |
DefaultCamelContext.setPollingConsumerServicePool(ServicePool<Endpoint,PollingConsumer> pollingConsumerServicePool) |
| Constructor and Description |
|---|
ConsumerCache(Object source,
CamelContext camelContext,
Map<String,PollingConsumer> cache) |
ConsumerCache(Object source,
CamelContext camelContext,
Map<String,PollingConsumer> cache,
ServicePool<Endpoint,PollingConsumer> pool) |
ConsumerCache(Object source,
CamelContext camelContext,
Map<String,PollingConsumer> cache,
ServicePool<Endpoint,PollingConsumer> pool) |
Apache Camel