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 and Description
protected 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.context.SmartLifecycle

DEFAULT_PHASE

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

OBJECT_TYPE_ATTRIBUTE

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AmqpBaseInboundChannelAdapterSpec(AmqpInboundChannelAdapter producer)

Method Summary

Modifier and Type	Method and 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	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, 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 Detail

headerMapper

protected final DefaultAmqpHeaderMapper headerMapper

Constructor Detail

AmqpBaseInboundChannelAdapterSpec

protected AmqpBaseInboundChannelAdapterSpec(AmqpInboundChannelAdapter producer)

Method Detail

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)