|
Spring Integration | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.springframework.integration.context.IntegrationObjectSupport org.springframework.integration.endpoint.AbstractEndpoint org.springframework.integration.endpoint.MessageProducerSupport org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter
public class AmqpInboundChannelAdapter
Adapter that receives Messages from an AMQP Queue, converts them into Spring Integration Messages, and sends the results to a Message Channel.
Field Summary |
---|
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport |
---|
logger |
Constructor Summary | |
---|---|
AmqpInboundChannelAdapter(org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer listenerContainer)
|
Method Summary | |
---|---|
int |
afterShutdown()
Called after normal shutdown of schedulers, executors etc, and after the shutdown delay has elapsed, but before any forced shutdown of any remaining active scheduler/executor threads.Can optionally return the number of active messages still in process. |
int |
beforeShutdown()
Called before shutdown begins. |
protected void |
doStart()
Takes no action by default. |
protected void |
doStop()
Takes no action by default. |
protected void |
onInit()
Subclasses may implement this for initialization logic. |
void |
setHeaderMapper(AmqpHeaderMapper headerMapper)
|
void |
setMessageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)
|
Methods inherited from class org.springframework.integration.endpoint.MessageProducerSupport |
---|
sendMessage, setErrorChannel, setOutputChannel, setSendTimeout, setShouldTrack |
Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint |
---|
getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop |
Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport |
---|
afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getComponentType, getConversionService, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, 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, getComponentType |
Constructor Detail |
---|
public AmqpInboundChannelAdapter(org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer listenerContainer)
Method Detail |
---|
public void setMessageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)
public void setHeaderMapper(AmqpHeaderMapper headerMapper)
protected void onInit()
IntegrationObjectSupport
onInit
in class MessageProducerSupport
protected void doStart()
MessageProducerSupport
doStart
in class MessageProducerSupport
protected void doStop()
MessageProducerSupport
doStop
in class MessageProducerSupport
public int beforeShutdown()
Shuts down the listener container.
beforeShutdown
in interface OrderlyShutdownCapable
public int afterShutdown()
No-op
afterShutdown
in interface OrderlyShutdownCapable
|
Spring Integration | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |