org.springframework.integration.amqp.channel

Class PointToPointSubscribableAmqpChannel

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.channel.AbstractMessageChannel

org.springframework.integration.amqp.channel.AbstractAmqpChannel

org.springframework.integration.amqp.channel.PointToPointSubscribableAmqpChannel

All Implemented Interfaces:

org.springframework.amqp.rabbit.connection.ConnectionListener, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, ChannelInterceptorAware, ExpressionCapable, NamedComponent, ConfigurableMetricsAware<AbstractMessageChannelMetrics>, IntegrationManagement, IntegrationStatsManagement, MessageChannelMetrics, TrackableComponent, org.springframework.messaging.MessageChannel, org.springframework.messaging.SubscribableChannel

public class PointToPointSubscribableAmqpChannel
extends AbstractAmqpChannel

Since:

2.1

Author:

Mark Fisher, Artem Bilan

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.integration.channel.AbstractMessageChannel

AbstractMessageChannel.ChannelInterceptorList

Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

Fields inherited from class org.springframework.integration.channel.AbstractMessageChannel

interceptors

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.messaging.MessageChannel

INDEFINITE_TIMEOUT

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Constructor Summary

Constructors

Constructor and Description
PointToPointSubscribableAmqpChannel(java.lang.String channelName, org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer container, org.springframework.amqp.core.AmqpTemplate amqpTemplate) Construct an instance with the supplied name, container and template; default header mappers will be used if the message is mapped.
PointToPointSubscribableAmqpChannel(java.lang.String channelName, org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer container, org.springframework.amqp.core.AmqpTemplate amqpTemplate, AmqpHeaderMapper outboundMapper, AmqpHeaderMapper inboundMapper) Construct an instance with the supplied name, container and template; default header mappers will be used if the message is mapped.

Method Summary

Modifier and Type	Method and Description
protected AbstractDispatcher	createDispatcher()
void	destroy()
protected void	doDeclares()
int	getPhase()
protected java.lang.String	getRoutingKey() Subclasses may override this method to return a routing key.
boolean	isAutoStartup()
boolean	isRunning()
protected java.lang.String	obtainQueueName(java.lang.String channelName)
void	onInit() Subclasses may implement this for initialization logic.
void	setMaxSubscribers(int maxSubscribers) Specify the maximum number of subscribers supported by the channel's dispatcher (if it is an AbstractDispatcher).
void	setQueueName(java.lang.String queueName) Provide a Queue name to be used.
void	start()
void	stop()
void	stop(java.lang.Runnable callback)
boolean	subscribe(org.springframework.messaging.MessageHandler handler)
boolean	unsubscribe(org.springframework.messaging.MessageHandler handler)

Methods inherited from class org.springframework.integration.amqp.channel.AbstractAmqpChannel

doSend, getAdmin, getAmqpTemplate, getConnectionFactory, getExchangeName, getInboundHeaderMapper, getRabbitTemplate, isExtractPayload, isLoggingEnabled, onClose, onCreate, setAdmin, setConnectionFactory, setDefaultDeliveryMode, setExtractPayload, setHeadersMappedLast, setLoggingEnabled

Methods inherited from class org.springframework.integration.channel.AbstractMessageChannel

addInterceptor, addInterceptor, configureMetrics, getChannelInterceptors, getComponentType, getErrorRate, getFullChannelName, getInterceptors, getMaxSendDuration, getMeanErrorRate, getMeanErrorRatio, getMeanSendDuration, getMeanSendRate, getMetrics, getMetricsCaptor, getMinSendDuration, getOverrides, getSendCount, getSendCountLong, getSendDuration, getSendErrorCount, getSendErrorCountLong, getSendRate, getStandardDeviationSendDuration, getTimeSinceLastSend, isCountsEnabled, isStatsEnabled, registerMetricsCaptor, removeInterceptor, removeInterceptor, reset, send, send, setCountsEnabled, setDatatypes, setInterceptors, setMessageConverter, setShouldTrack, setStatsEnabled

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.messaging.MessageChannel

send, send

Methods inherited from interface org.springframework.amqp.rabbit.connection.ConnectionListener

onShutDown

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

getComponentName

Constructor Detail

PointToPointSubscribableAmqpChannel

public PointToPointSubscribableAmqpChannel(java.lang.String channelName,
                                           org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer container,
                                           org.springframework.amqp.core.AmqpTemplate amqpTemplate)

Construct an instance with the supplied name, container and template; default header mappers will be used if the message is mapped.

Parameters:

channelName - the channel name.

container - the container.

amqpTemplate - the template.

See Also:

AbstractAmqpChannel.setExtractPayload(boolean)

PointToPointSubscribableAmqpChannel

public PointToPointSubscribableAmqpChannel(java.lang.String channelName,
                                           org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer container,
                                           org.springframework.amqp.core.AmqpTemplate amqpTemplate,
                                           AmqpHeaderMapper outboundMapper,
                                           AmqpHeaderMapper inboundMapper)

Construct an instance with the supplied name, container and template; default header mappers will be used if the message is mapped.

Parameters:

channelName - the channel name.

container - the container.

amqpTemplate - the template.

outboundMapper - the outbound mapper.

inboundMapper - the inbound mapper.

Since:

4.3

See Also:

AbstractAmqpChannel.setExtractPayload(boolean)

Method Detail

setQueueName

public void setQueueName(java.lang.String queueName)

Provide a Queue name to be used. If this is not provided, the Queue's name will be the same as the channel name.

Parameters:

queueName - The queue name.

obtainQueueName

protected java.lang.String obtainQueueName(java.lang.String channelName)

createDispatcher

protected AbstractDispatcher createDispatcher()

getRoutingKey

protected java.lang.String getRoutingKey()

Description copied from class: AbstractAmqpChannel

Subclasses may override this method to return a routing key. By default, there will be no routing key (empty string).

Overrides:

getRoutingKey in class AbstractAmqpChannel

Returns:

The routing key.

doDeclares

protected void doDeclares()

Specified by:

doDeclares in class AbstractAmqpChannel

setMaxSubscribers

public void setMaxSubscribers(int maxSubscribers)

Specify the maximum number of subscribers supported by the channel's dispatcher (if it is an AbstractDispatcher).

Parameters:

maxSubscribers - The maximum number of subscribers allowed.

subscribe

public boolean subscribe(org.springframework.messaging.MessageHandler handler)

Specified by:

subscribe in interface org.springframework.messaging.SubscribableChannel

unsubscribe

public boolean unsubscribe(org.springframework.messaging.MessageHandler handler)

Specified by:

unsubscribe in interface org.springframework.messaging.SubscribableChannel

onInit

public void onInit()
            throws java.lang.Exception

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class AbstractAmqpChannel

Throws:

java.lang.Exception - Any exception.

isAutoStartup

public boolean isAutoStartup()

Specified by:

isAutoStartup in interface org.springframework.context.SmartLifecycle

getPhase

public int getPhase()

Specified by:

getPhase in interface org.springframework.context.Phased

Specified by:

getPhase in interface org.springframework.context.SmartLifecycle

isRunning

public boolean isRunning()

Specified by:

isRunning in interface org.springframework.context.Lifecycle

start

public void start()

Specified by:

start in interface org.springframework.context.Lifecycle

stop

public void stop()

Specified by:

stop in interface org.springframework.context.Lifecycle

stop

public void stop(java.lang.Runnable callback)

Specified by:

stop in interface org.springframework.context.SmartLifecycle

destroy

public void destroy()
             throws java.lang.Exception

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Overrides:

destroy in class AbstractAmqpChannel

Throws:

java.lang.Exception