|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Closeable | |
---|---|
org.mule.streaming |
Uses of Closeable in org.mule.streaming |
---|
Subinterfaces of Closeable in org.mule.streaming | |
---|---|
interface |
Consumer<T>
General interface for components able to consume data from any specific resource or stream, following the Producer-Consumer design pattern. |
interface |
Producer<T>
A producer implementation that follows the idea of the Producer-Consumer design pattern. |
Classes in org.mule.streaming that implement Closeable | |
---|---|
class |
AbstractConsumer<T,P>
Base implementation of Consumer . |
class |
CompositeProducer<T>
Implementation of Producer to expose streams from several producers as a
single data feed. |
class |
ConsumerIterator<T>
Implementation of Iterator that takes its elements from a Consumer
. |
class |
ListableObjectStoreProducer<T extends Serializable>
Implementation of Producer to stream the contents of a
ListableObjectStore |
class |
ListConsumer<T>
Implementation of Consumer that obains a List
from a Producer and returns the elements one by one. |
class |
PagingDelegate<T>
A PagingDelegate is a Closeable capable of consuming a data feed in pages. |
class |
PagingDelegateProducer<T>
Implementation of Producer that uses an instance of PagingDelegate
to get its results |
class |
PagingDelegateWrapper<T>
This implementation of PagingDelegate takes care of enforcing some basic
behaviour of the delegate contract so that users don't have to. |
class |
QueueProducer<T>
Implementation of Producer to stream the contents of a
Queue A polling timeout value might be specified,
otherwise the default value of 5000 milliseconds will be assumed |
class |
SimpleConsumer<T>
Basic implementation of Consumer that simply returns the objects returned
by the underlying Producer |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |