org.springframework.integration.dsl

Class BarrierSpec

java.lang.Object

org.springframework.integration.dsl.core.IntegrationComponentSpec<S,Tuple2<F,H>>

org.springframework.integration.dsl.core.EndpointSpec<S,org.springframework.integration.config.ConsumerEndpointFactoryBean,H>

org.springframework.integration.dsl.core.ConsumerEndpointSpec<BarrierSpec,org.springframework.integration.aggregator.BarrierMessageHandler>

org.springframework.integration.dsl.BarrierSpec

All Implemented Interfaces:

org.springframework.beans.factory.FactoryBean<Tuple2<org.springframework.integration.config.ConsumerEndpointFactoryBean,org.springframework.integration.aggregator.BarrierMessageHandler>>, ComponentsRegistration

public class BarrierSpec
extends ConsumerEndpointSpec<BarrierSpec,org.springframework.integration.aggregator.BarrierMessageHandler>

A MessageHandlerSpec for the BarrierMessageHandler.

Since:

1.2

Author:

Artem Bilan

Field Summary

Fields inherited from class org.springframework.integration.dsl.core.ConsumerEndpointSpec

adviceChain

Fields inherited from class org.springframework.integration.dsl.core.EndpointSpec

componentToRegister, endpointFactoryBean, handler

Fields inherited from class org.springframework.integration.dsl.core.IntegrationComponentSpec

logger, PARSER, target

Method Summary

Modifier and Type	Method and Description
BarrierSpec	async(boolean async) Allow async replies.
BarrierSpec	correlationStrategy(org.springframework.integration.aggregator.CorrelationStrategy correlationStrategy)
Tuple2<org.springframework.integration.config.ConsumerEndpointFactoryBean,org.springframework.integration.aggregator.BarrierMessageHandler>	doGet()
BarrierSpec	order(int order)
BarrierSpec	outputProcessor(org.springframework.integration.aggregator.MessageGroupProcessor outputProcessor)
BarrierSpec	requiresReply(boolean requiresReply)
BarrierSpec	sendTimeout(long sendTimeout)

Methods inherited from class org.springframework.integration.dsl.core.ConsumerEndpointSpec

advice, autoStartup, phase, poller, transactional, transactional, transactional, transactional, transactional

Methods inherited from class org.springframework.integration.dsl.core.EndpointSpec

assertHandler, getComponentsToRegister, id, poller, poller

Methods inherited from class org.springframework.integration.dsl.core.IntegrationComponentSpec

_this, get, getId, getObject, getObjectType, isSingleton

Methods inherited from class java.lang.Object

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

Method Detail

outputProcessor

public BarrierSpec outputProcessor(org.springframework.integration.aggregator.MessageGroupProcessor outputProcessor)

correlationStrategy

public BarrierSpec correlationStrategy(org.springframework.integration.aggregator.CorrelationStrategy correlationStrategy)

requiresReply

public BarrierSpec requiresReply(boolean requiresReply)

Overrides:

requiresReply in class ConsumerEndpointSpec<BarrierSpec,org.springframework.integration.aggregator.BarrierMessageHandler>

Parameters:

requiresReply - the requiresReply.

Returns:

the endpoint spec.

See Also:

AbstractReplyProducingMessageHandler.setRequiresReply(boolean)

sendTimeout

public BarrierSpec sendTimeout(long sendTimeout)

Overrides:

sendTimeout in class ConsumerEndpointSpec<BarrierSpec,org.springframework.integration.aggregator.BarrierMessageHandler>

Parameters:

sendTimeout - the send timeout.

Returns:

the endpoint spec.

See Also:

AbstractMessageProducingHandler.setSendTimeout(long)

order

public BarrierSpec order(int order)

Overrides:

order in class ConsumerEndpointSpec<BarrierSpec,org.springframework.integration.aggregator.BarrierMessageHandler>

Parameters:

order - the order.

Returns:

the endpoint spec.

See Also:

AbstractMessageHandler.setOrder(int)

async

public BarrierSpec async(boolean async)

Description copied from class: ConsumerEndpointSpec

Allow async replies. If the handler reply is a ListenableFuture send the output when it is satisfied rather than sending the future as the result. Only subclasses that support this feature should set it.

Overrides:

async in class ConsumerEndpointSpec<BarrierSpec,org.springframework.integration.aggregator.BarrierMessageHandler>

Parameters:

async - true to allow.

Returns:

the endpoint spec.

See Also:

AbstractMessageProducingHandler.setAsync(boolean)

doGet

public Tuple2<org.springframework.integration.config.ConsumerEndpointFactoryBean,org.springframework.integration.aggregator.BarrierMessageHandler> doGet()

Overrides:

doGet in class EndpointSpec<BarrierSpec,org.springframework.integration.config.ConsumerEndpointFactoryBean,org.springframework.integration.aggregator.BarrierMessageHandler>