Package | Description |
---|---|
org.mule.streaming |
Modifier and Type | Class and Description |
---|---|
class |
CompositeProducer<T>
Implementation of
Producer to expose streams from several producers as a
single data feed. |
class |
ListableObjectStoreProducer<T extends Serializable>
Implementation of
Producer to stream the contents of a
ListableObjectStore |
class |
PagingDelegateProducer<T>
Implementation of
Producer that uses an instance of PagingDelegate
to get its results |
class |
QueueProducer<T>
|
Modifier and Type | Field and Description |
---|---|
protected Producer<P> |
AbstractConsumer.producer |
Constructor and Description |
---|
AbstractConsumer(Producer<P> producer) |
CompositeProducer(Producer<T>... producers) |
ListConsumer(Producer<List<T>> producer) |
SimpleConsumer(Producer<T> producer) |
Constructor and Description |
---|
CompositeProducer(List<Producer<T>> producers)
Takes a list of producers to be composited.
|
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.