public class PollableAmqpChannel extends AbstractAmqpChannel implements PollableChannel
PollableChannel implementation that is backed by an AMQP Queue.
Messages will be sent to the default (no-name) exchange with that Queue's
name as the routing key.AbstractMessageChannel.ChannelInterceptorListloggerINDEFINITE_TIMEOUT| Constructor and Description |
|---|
PollableAmqpChannel(String channelName,
AmqpTemplate amqpTemplate) |
| Modifier and Type | Method and Description |
|---|---|
protected String |
getRoutingKey()
Subclasses may override this method to return a routing key.
|
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
Message<?> |
receive() |
Message<?> |
receive(long timeout) |
void |
setAmqpAdmin(AmqpAdmin amqpAdmin)
Provide an instance of AmqpAdmin for implicitly declaring Queues if the queueName is not provided.
|
void |
setQueueName(String queueName)
Provide an explicitly configured queue name.
|
doSend, getExchangeNameaddInterceptor, addInterceptor, getChannelInterceptors, getComponentType, getFullChannelName, getInterceptors, removeInterceptor, removeInterceptor, send, send, setConversionService, setDatatypes, setInterceptors, setMessageConverter, setShouldTrackafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setMessageBuilderFactory, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitsend, sendgetComponentNamepublic PollableAmqpChannel(String channelName, AmqpTemplate amqpTemplate)
public void setQueueName(String queueName)
queueName - The queue name.public void setAmqpAdmin(AmqpAdmin amqpAdmin)
amqpAdmin - The amqp admin.protected void onInit()
throws Exception
IntegrationObjectSupportonInit in class AbstractMessageChannelException - Any exception.protected String getRoutingKey()
AbstractAmqpChannelgetRoutingKey in class AbstractAmqpChannelpublic Message<?> receive()
receive in interface PollableChannelpublic Message<?> receive(long timeout)
receive in interface PollableChannel