|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use PollingConsumer | |
---|---|
org.apache.camel | The core Camel API |
org.apache.camel.component.dataset | A DataSet Endpoint for testing of endpoints using defined DataSets |
org.apache.camel.component.seda | The SEDA Component for asynchronous SEDA exchanges on a BlockingQueue within a single CamelContext |
org.apache.camel.impl | Default implementation classes for Camel Core |
Uses of PollingConsumer in org.apache.camel |
---|
Methods in org.apache.camel that return PollingConsumer | |
---|---|
PollingConsumer<E> |
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) |
Uses of PollingConsumer in org.apache.camel.component.dataset |
---|
Methods in org.apache.camel.component.dataset that return PollingConsumer | |
---|---|
PollingConsumer<Exchange> |
DataSetEndpoint.createPollingConsumer()
|
Uses of PollingConsumer in org.apache.camel.component.seda |
---|
Classes in org.apache.camel.component.seda that implement PollingConsumer | |
---|---|
class |
ListPollingConsumer
|
Uses of PollingConsumer in org.apache.camel.impl |
---|
Classes in org.apache.camel.impl that implement PollingConsumer | |
---|---|
class |
EventDrivenPollingConsumer<E extends Exchange>
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<E extends Exchange>
A useful base class for implementations of PollingConsumer |
class |
ProcessorPollingConsumer
A simple implementation of PollingConsumer which just uses
a Processor . |
Methods in org.apache.camel.impl that return PollingConsumer | |
---|---|
PollingConsumer<E> |
DefaultEndpoint.createPollingConsumer()
|
PollingConsumer<Exchange> |
ProcessorEndpoint.createPollingConsumer()
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |