org.springframework.integration.aggregator
Class AggregatorMessageHandlerCreator

java.lang.Object
  org.springframework.integration.handler.config.AbstractMessageHandlerCreator
      org.springframework.integration.aggregator.AggregatorMessageHandlerCreator

All Implemented Interfaces:

MessageHandlerCreator

public class AggregatorMessageHandlerCreator
extends AbstractMessageHandlerCreator

Creates an AggregatorAdapter for methods that aggregate messages.

Author:

Marius Bogoevici

Field Summary

private ChannelRegistry	channelRegistry
private static java.lang.String	DISCARD_CHANNEL
private static java.lang.String	REAPER_INTERVAL
private static java.lang.String	SEND_PARTIAL_RESULTS_ON_TIMEOUT
private static java.lang.String	SEND_TIMEOUT
private static java.lang.String	TIMEOUT
private static java.lang.String	TRACKED_CORRELATION_ID_CAPACITY

Constructor Summary

AggregatorMessageHandlerCreator(ChannelRegistry channelRegistry)

Method Summary

private void	configureCompletionStrategy(java.lang.Object object, AggregatingMessageHandler handler)
private void	configureDefaultReplyChannel(AggregatingMessageHandler handler, java.lang.Object originalObject)
MessageHandler	doCreateHandler(java.lang.Object object, java.lang.reflect.Method method, java.util.Map<java.lang.String,?> attributes)
private <T> T	getAttribute(java.util.Map<java.lang.String,?> attributes, java.lang.String name, java.lang.Class<T> expectedType)

Methods inherited from class org.springframework.integration.handler.config.AbstractMessageHandlerCreator

createHandler

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DISCARD_CHANNEL

private static final java.lang.String DISCARD_CHANNEL

See Also:

Constant Field Values

SEND_TIMEOUT

private static final java.lang.String SEND_TIMEOUT

See Also:

Constant Field Values

SEND_PARTIAL_RESULTS_ON_TIMEOUT

private static final java.lang.String SEND_PARTIAL_RESULTS_ON_TIMEOUT

See Also:

Constant Field Values

REAPER_INTERVAL

private static final java.lang.String REAPER_INTERVAL

See Also:

Constant Field Values

TIMEOUT

private static final java.lang.String TIMEOUT

See Also:

Constant Field Values

TRACKED_CORRELATION_ID_CAPACITY

private static final java.lang.String TRACKED_CORRELATION_ID_CAPACITY

See Also:

Constant Field Values

channelRegistry

private final ChannelRegistry channelRegistry

Constructor Detail

AggregatorMessageHandlerCreator

public AggregatorMessageHandlerCreator(ChannelRegistry channelRegistry)

Method Detail

doCreateHandler

public MessageHandler doCreateHandler(java.lang.Object object,
                                      java.lang.reflect.Method method,
                                      java.util.Map<java.lang.String,?> attributes)

Specified by:

doCreateHandler in class AbstractMessageHandlerCreator

configureDefaultReplyChannel

private void configureDefaultReplyChannel(AggregatingMessageHandler handler,
                                          java.lang.Object originalObject)

configureCompletionStrategy

private void configureCompletionStrategy(java.lang.Object object,
                                         AggregatingMessageHandler handler)

getAttribute

private <T> T getAttribute(java.util.Map<java.lang.String,?> attributes,
                           java.lang.String name,
                           java.lang.Class<T> expectedType)