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 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

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

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)