|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.apache.camel.model.OptionalIdentifiedType<Type>
org.apache.camel.model.ProcessorDefinition<Type>
org.apache.camel.model.OutputDefinition<ProcessorDefinition>
org.apache.camel.model.MulticastDefinition
public class MulticastDefinition
Represents an XML <multicast/> element
| Field Summary |
|---|
| Fields inherited from class org.apache.camel.model.OutputDefinition |
|---|
outputs |
| Fields inherited from class org.apache.camel.model.OptionalIdentifiedType |
|---|
nodeCounters |
| Constructor Summary | |
|---|---|
MulticastDefinition()
|
|
| Method Summary | |
|---|---|
MulticastDefinition |
aggregationStrategy(AggregationStrategy aggregationStrategy)
Set the multicasting aggregationStrategy |
protected Processor |
createCompositeProcessor(RouteContext routeContext,
List<Processor> list)
Creates a new instance of some kind of composite processor which defaults to using a Pipeline but derived classes could change the behaviour |
Processor |
createProcessor(RouteContext routeContext)
|
MulticastDefinition |
executorService(ExecutorService executorService)
Setting the executor service for executing the multicasting action. |
AggregationStrategy |
getAggregationStrategy()
|
ExecutorService |
getExecutorService()
|
String |
getShortName()
Returns a short name for this node which can be useful for ID generation or referring to related resources like images |
boolean |
isParallelProcessing()
|
boolean |
isStreaming()
|
MulticastDefinition |
parallelProcessing()
Uses the ExecutorService to do the multicasting work |
MulticastDefinition |
setAggregationStrategy(AggregationStrategy aggregationStrategy)
|
void |
setExecutorService(ExecutorService executorService)
|
void |
setParallelProcessing(boolean parallelProcessing)
|
void |
setStreaming(boolean streaming)
|
MulticastDefinition |
streaming()
Aggregates the responses as the are done (e.g. |
String |
toString()
|
| Methods inherited from class org.apache.camel.model.OutputDefinition |
|---|
getOutputs, setOutputs |
| Methods inherited from class org.apache.camel.model.OptionalIdentifiedType |
|---|
createId, description, getDescription, getId, getNodeCounter, hasCustomIdAssigned, idOrCreate, setDescription, setId |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
| Constructor Detail |
|---|
public MulticastDefinition()
| Method Detail |
|---|
public String toString()
toString in class Objectpublic String getShortName()
OptionalIdentifiedType
getShortName in class OptionalIdentifiedType<ProcessorDefinition>
public Processor createProcessor(RouteContext routeContext)
throws Exception
createProcessor in class ProcessorDefinition<ProcessorDefinition>Exceptionpublic MulticastDefinition aggregationStrategy(AggregationStrategy aggregationStrategy)
public MulticastDefinition parallelProcessing()
ExecutorService to do the multicasting work
public MulticastDefinition streaming()
public MulticastDefinition executorService(ExecutorService executorService)
protected Processor createCompositeProcessor(RouteContext routeContext,
List<Processor> list)
ProcessorDefinitionPipeline but derived classes could change the behaviour
createCompositeProcessor in class ProcessorDefinition<ProcessorDefinition>public AggregationStrategy getAggregationStrategy()
public MulticastDefinition setAggregationStrategy(AggregationStrategy aggregationStrategy)
public boolean isParallelProcessing()
public void setParallelProcessing(boolean parallelProcessing)
public boolean isStreaming()
public void setStreaming(boolean streaming)
public ExecutorService getExecutorService()
public void setExecutorService(ExecutorService executorService)
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||