public class DefaultAggregateController extends Object implements AggregateController
AggregateController that offers Java and JMX API.| Constructor and Description |
|---|
DefaultAggregateController() |
| Modifier and Type | Method and Description |
|---|---|
int |
forceCompletionOfAllGroups()
To force complete of all groups
|
int |
forceCompletionOfGroup(String key)
To force completing a specific group by its key.
|
void |
onStart(AggregateProcessor processor)
Callback when the aggregate processor is started.
|
void |
onStop(AggregateProcessor processor)
Callback when the aggregate processor is stopped.
|
public DefaultAggregateController()
public void onStart(AggregateProcessor processor)
AggregateControlleronStart in interface AggregateControllerprocessor - the aggregate processorpublic void onStop(AggregateProcessor processor)
AggregateControlleronStop in interface AggregateControllerprocessor - the aggregate processorpublic int forceCompletionOfGroup(String key)
AggregateControllerforceCompletionOfGroup in interface AggregateControllerkey - the keypublic int forceCompletionOfAllGroups()
AggregateControllerforceCompletionOfAllGroups in interface AggregateControllerApache Camel