Class AbstractAmqpChannel

  extended by org.springframework.integration.context.IntegrationObjectSupport
      extended by
          extended by
All Implemented Interfaces:
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


Nested Class Summary
Nested classes/interfaces inherited from class
Field Summary
Fields inherited from class
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
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

Method Detail


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.


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


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