org.springframework.integration.amqp.channel
Class AbstractAmqpChannel

java.lang.Object
  org.springframework.integration.context.IntegrationObjectSupport
      org.springframework.integration.channel.AbstractMessageChannel
          org.springframework.integration.amqp.channel.AbstractAmqpChannel

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, NamedComponent, TrackableComponent, MessageChannel

Direct Known Subclasses:

PointToPointSubscribableAmqpChannel, PollableAmqpChannel, PublishSubscribeAmqpChannel

public abstract class AbstractAmqpChannel
extends AbstractMessageChannel

Since:

2.1

Author:

Mark Fisher

Nested Class Summary

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

AbstractMessageChannel.ChannelInterceptorList

Field Summary

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

logger

Method Summary

protected boolean	doSend(Message<?> message, long timeout) Subclasses must implement this method.
protected java.lang.String	getExchangeName() Subclasses may override this method to return an Exchange name.
protected java.lang.String	getRoutingKey() Subclasses may override this method to return a routing key.

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

addInterceptor, getComponentType, getInterceptors, send, send, setConversionService, setDatatypes, setInterceptors, setShouldTrack

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

afterPropertiesSet, getBeanFactory, getComponentName, getConversionService, getTaskScheduler, onInit, setBeanFactory, setBeanName, setComponentName, 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.integration.context.NamedComponent

getComponentName

Method Detail

getExchangeName

protected java.lang.String getExchangeName()

Subclasses may override this method to return an Exchange name. By default, Messages will be sent to the no-name Direct Exchange.

getRoutingKey

protected java.lang.String getRoutingKey()

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

doSend

protected boolean doSend(Message<?> message,
                         long timeout)

Description copied from class: AbstractMessageChannel

Subclasses must implement this method. A non-negative timeout indicates how long to wait if the channel is at capacity (if the value is 0, it must return immediately with or without success). A negative timeout value indicates that the method should block until either the message is accepted or the blocking thread is interrupted.

Specified by:

doSend in class AbstractMessageChannel