Hi, here's my aggregator:
Code:
@MessageEndpoint(input = Channels.AGGREGATOR_CHANNEL, output = Channels.LOG_CHANNEL)
//@Concurrency(coreSize = 3 , maxSize = 3)
public class MessageAggregator {
@Aggregator(sendTimeout = 20000L, sendPartialResultsOnTimeout = true)
public String aggregateMessages(final List<Message> messages) {
final StringBuilder stringBuilder = new StringBuilder();
LOGGER.info("# of messages: {}", messages.size());
for (Message stringMessage : messages) {
stringBuilder.append(stringMessage.getPayload().toString());
}
return stringBuilder.toString();
}
Added my configuration as attachments.