|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
public interface BatchConsumer
A consumer of a batch of message exchanges from an Endpoint
| Method Summary | |
|---|---|
void |
processBatch(Queue exchanges)
Processes the list of Exchange in a batch. |
void |
setMaxMessagesPerPoll(int maxMessagesPerPoll)
Sets a maximum number of messages as a limit to poll at each polling. |
| Methods inherited from interface org.apache.camel.Service |
|---|
start, stop |
| Method Detail |
|---|
void setMaxMessagesPerPoll(int maxMessagesPerPoll)
maxMessagesPerPoll - maximum messages to poll.
void processBatch(Queue exchanges)
throws Exception
Exchange in a batch.
Each message exchange will be processed individually but the batch
consumer will add properties with the current index and total in the batch.
exchanges - list of exchanges in this batch
Exception - if an internal processing error has occurred.
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||