Package org.springframework.integration.amqp.dsl

Class AmqpBaseInboundChannelAdapterSpec<S extends AmqpBaseInboundChannelAdapterSpec<S>>

java.lang.Object

org.springframework.beans.factory.config.AbstractFactoryBean<T>

org.springframework.integration.dsl.IntegrationComponentSpec<S,P>

org.springframework.integration.dsl.MessageProducerSpec<S,AmqpInboundChannelAdapter>

org.springframework.integration.amqp.dsl.AmqpBaseInboundChannelAdapterSpec<S>

Type Parameters:

S - the target AmqpBaseInboundChannelAdapterSpec implementation type.

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, DisposableBean, FactoryBean<AmqpInboundChannelAdapter>, InitializingBean, Lifecycle, Phased, SmartLifecycle

Direct Known Subclasses:

AmqpInboundChannelAdapterSpec

public class AmqpBaseInboundChannelAdapterSpec<S extends AmqpBaseInboundChannelAdapterSpec<S>>
extends MessageProducerSpec<S,AmqpInboundChannelAdapter>

The base MessageProducerSpec implementation for a AmqpInboundChannelAdapter.

Since:

5.0

Author:

Artem Bilan

Field Summary

Fields

Modifier and Type	Field	Description
protected final DefaultAmqpHeaderMapper	headerMapper

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

PARSER, target

Fields inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

logger

Fields inherited from interface org.springframework.beans.factory.FactoryBean

OBJECT_TYPE_ATTRIBUTE

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AmqpBaseInboundChannelAdapterSpec(AmqpInboundChannelAdapter producer)

Method Summary

Modifier and Type	Method	Description
S	headerMapper(AmqpHeaderMapper headerMapper)	Configure the adapter's AmqpHeaderMapper; defaults to DefaultAmqpHeaderMapper.
S	mappedRequestHeaders(String... headers)	Only applies if the default header mapper is used.
S	messageConverter(MessageConverter messageConverter)	Configure the adapter's MessageConverter; defaults to SimpleMessageConverter.
S	messageRecoverer(MessageRecoverer messageRecoverer)	Set a MessageRecoverer when using retry within the adapter.
S	recoveryCallback(org.springframework.retry.RecoveryCallback<?> recoveryCallback)	Set a RecoveryCallback when using retry within the adapter.
S	retryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)	Set a RetryTemplate to use for retrying a message delivery within the adapter.

Methods inherited from class org.springframework.integration.dsl.MessageProducerSpec

autoStartup, errorChannel, errorChannel, errorMessageStrategy, id, observationConvention, outputChannel, outputChannel, phase, sendTimeout, shouldTrack

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

_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop

Methods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton

Methods inherited from class java.lang.Object

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

Field Details

headerMapper

protected final DefaultAmqpHeaderMapper headerMapper

Constructor Details

AmqpBaseInboundChannelAdapterSpec

protected AmqpBaseInboundChannelAdapterSpec(AmqpInboundChannelAdapter producer)

Method Details

messageConverter

public S messageConverter(MessageConverter messageConverter)

Configure the adapter's MessageConverter; defaults to SimpleMessageConverter.

Parameters:

messageConverter - the messageConverter.

Returns:

the spec.

See Also:

• AmqpInboundChannelAdapter.setMessageConverter(org.springframework.amqp.support.converter.MessageConverter)

headerMapper

public S headerMapper(AmqpHeaderMapper headerMapper)

Configure the adapter's AmqpHeaderMapper; defaults to DefaultAmqpHeaderMapper.

Parameters:

headerMapper - the headerMapper.

Returns:

the spec.

mappedRequestHeaders

public S mappedRequestHeaders(String... headers)

Only applies if the default header mapper is used.

Parameters:

headers - the headers.

Returns:

the spec.

See Also:

• AbstractHeaderMapper.setRequestHeaderNames(String[])

retryTemplate

public S retryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)

Set a RetryTemplate to use for retrying a message delivery within the adapter.

Parameters:

retryTemplate - the template.

Returns:

the spec.

Since:

5.0.2

See Also:

• AmqpInboundChannelAdapter.setRetryTemplate(RetryTemplate)

recoveryCallback

public S recoveryCallback(org.springframework.retry.RecoveryCallback<?> recoveryCallback)

Set a RecoveryCallback when using retry within the adapter.

Parameters:

recoveryCallback - the callback.

Returns:

the spec.

Since:

5.0.2

See Also:

• AmqpInboundChannelAdapter.setRecoveryCallback(RecoveryCallback)

messageRecoverer

public S messageRecoverer(MessageRecoverer messageRecoverer)

Set a MessageRecoverer when using retry within the adapter.

Parameters:

messageRecoverer - the callback.

Returns:

the spec.

Since:

5.5

See Also:

• AmqpInboundChannelAdapter.setMessageRecoverer(MessageRecoverer)