Overview
Package
Class
Tree
Deprecated
Index
Help
PREV NEXT
FRAMES
NO FRAMES
All Classes
A
B
C
D
E
G
H
I
M
O
P
R
S
T
U
A
AbstractAmqpChannel
- Class in
org.springframework.integration.amqp.channel
afterShutdown()
- Method in class org.springframework.integration.amqp.inbound.
AmqpInboundChannelAdapter
No-op
AmqpChannelFactoryBean
- Class in
org.springframework.integration.amqp.config
If point-to-point, we send to the default exchange with the routing key equal to "[beanName]" and we declare that same Queue and register a listener if message-driven or poll explicitly otherwise.
AmqpChannelFactoryBean()
- Constructor for class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
AmqpChannelFactoryBean(boolean)
- Constructor for class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
AmqpChannelParser
- Class in
org.springframework.integration.amqp.config
Parser for the 'channel' and 'publish-subscribe-channel' elements of the Spring Integration AMQP namespace.
AmqpChannelParser()
- Constructor for class org.springframework.integration.amqp.config.
AmqpChannelParser
AmqpHeaderMapper
- Interface in
org.springframework.integration.amqp.support
A convenience interface that extends
HeaderMapper
but parameterized with
MessageProperties
.
AmqpHeaders
- Class in
org.springframework.integration.amqp
Pre-defined names and prefixes to be used for setting and/or retrieving AMQP MessageProperties from/to integration Message Headers.
AmqpHeaders()
- Constructor for class org.springframework.integration.amqp.
AmqpHeaders
AmqpInboundChannelAdapter
- Class in
org.springframework.integration.amqp.inbound
Adapter that receives Messages from an AMQP Queue, converts them into Spring Integration Messages, and sends the results to a Message Channel.
AmqpInboundChannelAdapter(AbstractMessageListenerContainer)
- Constructor for class org.springframework.integration.amqp.inbound.
AmqpInboundChannelAdapter
AmqpInboundChannelAdapterParser
- Class in
org.springframework.integration.amqp.config
Parser for the AMQP 'inbound-channel-adapter' element.
AmqpInboundGateway
- Class in
org.springframework.integration.amqp.inbound
Adapter that receives Messages from an AMQP Queue, converts them into Spring Integration Messages, and sends the results to a Message Channel.
AmqpInboundGateway(AbstractMessageListenerContainer)
- Constructor for class org.springframework.integration.amqp.inbound.
AmqpInboundGateway
AmqpInboundGatewayParser
- Class in
org.springframework.integration.amqp.config
Parser for the AMQP 'inbound-gateway' element.
AmqpNamespaceHandler
- Class in
org.springframework.integration.amqp.config
Namespace handler for the AMQP schema.
AmqpNamespaceHandler()
- Constructor for class org.springframework.integration.amqp.config.
AmqpNamespaceHandler
AmqpOutboundChannelAdapterParser
- Class in
org.springframework.integration.amqp.config
Parser for the AMQP 'outbound-channel-adapter' element.
AmqpOutboundChannelAdapterParser()
- Constructor for class org.springframework.integration.amqp.config.
AmqpOutboundChannelAdapterParser
AmqpOutboundEndpoint
- Class in
org.springframework.integration.amqp.outbound
Adapter that converts and sends Messages to an AMQP Exchange.
AmqpOutboundEndpoint(AmqpTemplate)
- Constructor for class org.springframework.integration.amqp.outbound.
AmqpOutboundEndpoint
AmqpOutboundGatewayParser
- Class in
org.springframework.integration.amqp.config
Parser for the AMQP 'outbound-channel-adapter' element.
AmqpOutboundGatewayParser()
- Constructor for class org.springframework.integration.amqp.config.
AmqpOutboundGatewayParser
APP_ID
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
B
beforeShutdown()
- Method in class org.springframework.integration.amqp.inbound.
AmqpInboundChannelAdapter
Shuts down the listener container.
buildBeanDefinition(Element, ParserContext)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelParser
C
CLUSTER_ID
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
configureChannels(Element, ParserContext, BeanDefinitionBuilder)
- Method in class org.springframework.integration.amqp.config.
AmqpInboundChannelAdapterParser
configureChannels(Element, ParserContext, BeanDefinitionBuilder)
- Method in class org.springframework.integration.amqp.config.
AmqpInboundGatewayParser
confirm(CorrelationData, boolean)
- Method in class org.springframework.integration.amqp.outbound.
AmqpOutboundEndpoint
CONTENT_ENCODING
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
CONTENT_LENGTH
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
CONTENT_TYPE
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
CORRELATION_ID
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
createDispatcher()
- Method in class org.springframework.integration.amqp.channel.
PointToPointSubscribableAmqpChannel
createDispatcher()
- Method in class org.springframework.integration.amqp.channel.
PublishSubscribeAmqpChannel
createInstance()
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
D
DefaultAmqpHeaderMapper
- Class in
org.springframework.integration.amqp.support
Default implementation of
AmqpHeaderMapper
.
DefaultAmqpHeaderMapper()
- Constructor for class org.springframework.integration.amqp.support.
DefaultAmqpHeaderMapper
DELIVERY_MODE
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
DELIVERY_TAG
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
destroyInstance(AbstractAmqpChannel)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
doSend(Message<?>, long)
- Method in class org.springframework.integration.amqp.channel.
AbstractAmqpChannel
doStart()
- Method in class org.springframework.integration.amqp.inbound.
AmqpInboundChannelAdapter
doStart()
- Method in class org.springframework.integration.amqp.inbound.
AmqpInboundGateway
doStop()
- Method in class org.springframework.integration.amqp.inbound.
AmqpInboundChannelAdapter
doStop()
- Method in class org.springframework.integration.amqp.inbound.
AmqpInboundGateway
E
EXPIRATION
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
extractStandardHeaders(MessageProperties)
- Method in class org.springframework.integration.amqp.support.
DefaultAmqpHeaderMapper
Extract "standard" headers from an AMQP MessageProperties instance.
extractUserDefinedHeaders(MessageProperties)
- Method in class org.springframework.integration.amqp.support.
DefaultAmqpHeaderMapper
Extract user-defined headers from an AMQP MessageProperties instance.
G
getComponentType()
- Method in class org.springframework.integration.amqp.outbound.
AmqpOutboundEndpoint
getExchangeName()
- Method in class org.springframework.integration.amqp.channel.
AbstractAmqpChannel
Subclasses may override this method to return an Exchange name.
getExchangeName()
- Method in class org.springframework.integration.amqp.channel.
PublishSubscribeAmqpChannel
getInputChannelAttributeName()
- Method in class org.springframework.integration.amqp.config.
AmqpOutboundGatewayParser
getObjectType()
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
getPhase()
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
getRoutingKey()
- Method in class org.springframework.integration.amqp.channel.
AbstractAmqpChannel
Subclasses may override this method to return a routing key.
getRoutingKey()
- Method in class org.springframework.integration.amqp.channel.
PointToPointSubscribableAmqpChannel
getRoutingKey()
- Method in class org.springframework.integration.amqp.channel.
PollableAmqpChannel
getStandardHeaderPrefix()
- Method in class org.springframework.integration.amqp.support.
DefaultAmqpHeaderMapper
getStandardReplyHeaderNames()
- Method in class org.springframework.integration.amqp.support.
DefaultAmqpHeaderMapper
getStandardRequestHeaderNames()
- Method in class org.springframework.integration.amqp.support.
DefaultAmqpHeaderMapper
H
handleRequestMessage(Message<?>)
- Method in class org.springframework.integration.amqp.outbound.
AmqpOutboundEndpoint
I
init()
- Method in class org.springframework.integration.amqp.config.
AmqpNamespaceHandler
initializeQueue(AmqpAdmin, String)
- Method in class org.springframework.integration.amqp.channel.
PointToPointSubscribableAmqpChannel
initializeQueue(AmqpAdmin, String)
- Method in class org.springframework.integration.amqp.channel.
PublishSubscribeAmqpChannel
isAutoStartup()
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
isRunning()
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
M
MESSAGE_COUNT
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
MESSAGE_ID
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
O
onInit()
- Method in class org.springframework.integration.amqp.channel.
PollableAmqpChannel
onInit()
- Method in class org.springframework.integration.amqp.inbound.
AmqpInboundChannelAdapter
onInit()
- Method in class org.springframework.integration.amqp.inbound.
AmqpInboundGateway
onInit()
- Method in class org.springframework.integration.amqp.outbound.
AmqpOutboundEndpoint
org.springframework.integration.amqp
- package org.springframework.integration.amqp
Base package for AMQP support.
org.springframework.integration.amqp.channel
- package org.springframework.integration.amqp.channel
Provides classes related to AMQP-backed channels.
org.springframework.integration.amqp.config
- package org.springframework.integration.amqp.config
Provides classes for configuration - parsers, namespace handlers, factory beans.
org.springframework.integration.amqp.inbound
- package org.springframework.integration.amqp.inbound
Provides classes supporting inbound endpoints.
org.springframework.integration.amqp.outbound
- package org.springframework.integration.amqp.outbound
Provides classes supporting outbound endpoints.
org.springframework.integration.amqp.support
- package org.springframework.integration.amqp.support
Provides AMQP support classes.
P
parseConsumer(Element, ParserContext)
- Method in class org.springframework.integration.amqp.config.
AmqpOutboundChannelAdapterParser
parseHandler(Element, ParserContext)
- Method in class org.springframework.integration.amqp.config.
AmqpOutboundGatewayParser
PointToPointSubscribableAmqpChannel
- Class in
org.springframework.integration.amqp.channel
PointToPointSubscribableAmqpChannel(String, SimpleMessageListenerContainer, AmqpTemplate)
- Constructor for class org.springframework.integration.amqp.channel.
PointToPointSubscribableAmqpChannel
PollableAmqpChannel
- Class in
org.springframework.integration.amqp.channel
A
PollableChannel
implementation that is backed by an AMQP Queue.
PollableAmqpChannel(String, AmqpTemplate)
- Constructor for class org.springframework.integration.amqp.channel.
PollableAmqpChannel
populateStandardHeaders(Map<String, Object>, MessageProperties)
- Method in class org.springframework.integration.amqp.support.
DefaultAmqpHeaderMapper
Maps headers from a Spring Integration MessageHeaders instance to the MessageProperties of an AMQP Message.
populateUserDefinedHeader(String, Object, MessageProperties)
- Method in class org.springframework.integration.amqp.support.
DefaultAmqpHeaderMapper
PREFIX
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
Prefix used for AMQP related headers in order to distinguish from user-defined headers and other internal headers (e.g.
PUBLISH_CONFIRM
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
PublishSubscribeAmqpChannel
- Class in
org.springframework.integration.amqp.channel
PublishSubscribeAmqpChannel(String, SimpleMessageListenerContainer, AmqpTemplate)
- Constructor for class org.springframework.integration.amqp.channel.
PublishSubscribeAmqpChannel
R
receive()
- Method in class org.springframework.integration.amqp.channel.
PollableAmqpChannel
receive(long)
- Method in class org.springframework.integration.amqp.channel.
PollableAmqpChannel
RECEIVED_EXCHANGE
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
RECEIVED_ROUTING_KEY
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
REDELIVERED
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
REPLY_TO
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
resolveId(Element, AbstractBeanDefinition, ParserContext)
- Method in class org.springframework.integration.amqp.config.
AmqpInboundChannelAdapterParser
RETURN_EXCHANGE
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
RETURN_REPLY_CODE
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
RETURN_REPLY_TEXT
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
RETURN_ROUTING_KEY
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
returnedMessage(Message, int, String, String, String)
- Method in class org.springframework.integration.amqp.outbound.
AmqpOutboundEndpoint
S
setAcknowledgeMode(AcknowledgeMode)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setAdviceChain(Advice[])
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setAmqpAdmin(AmqpAdmin)
- Method in class org.springframework.integration.amqp.channel.
PollableAmqpChannel
Provide an instance of AmqpAdmin for implicitly declaring Queues if the queueName is not provided.
setAmqpAdmin(AmqpAdmin)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
This is an optional reference to an AmqpAdmin to use when declaring a Queue implicitly for a PollableAmqpChannel.
setAutoStartup(boolean)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setBeanName(String)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setChannelTransacted(boolean)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setConcurrentConsumers(int)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setConfirmAckChannel(MessageChannel)
- Method in class org.springframework.integration.amqp.outbound.
AmqpOutboundEndpoint
setConfirmCorrelationExpression(String)
- Method in class org.springframework.integration.amqp.outbound.
AmqpOutboundEndpoint
setConfirmNackChannel(MessageChannel)
- Method in class org.springframework.integration.amqp.outbound.
AmqpOutboundEndpoint
setConnectionFactory(ConnectionFactory)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setEncoding(String)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setErrorHandler(ErrorHandler)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setExchange(FanoutExchange)
- Method in class org.springframework.integration.amqp.channel.
PublishSubscribeAmqpChannel
Configure the FanoutExchange instance.
setExchange(FanoutExchange)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
Set the FanoutExchange to use.
setExchangeName(String)
- Method in class org.springframework.integration.amqp.outbound.
AmqpOutboundEndpoint
setExchangeNameExpression(String)
- Method in class org.springframework.integration.amqp.outbound.
AmqpOutboundEndpoint
setExpectReply(boolean)
- Method in class org.springframework.integration.amqp.outbound.
AmqpOutboundEndpoint
setExposeListenerChannel(boolean)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setHeaderMapper(AmqpHeaderMapper)
- Method in class org.springframework.integration.amqp.inbound.
AmqpInboundChannelAdapter
setHeaderMapper(AmqpHeaderMapper)
- Method in class org.springframework.integration.amqp.inbound.
AmqpInboundGateway
setHeaderMapper(AmqpHeaderMapper)
- Method in class org.springframework.integration.amqp.outbound.
AmqpOutboundEndpoint
setInterceptors(List<ChannelInterceptor>)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setMaxSubscribers(int)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setMessageConverter(MessageConverter)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setMessageConverter(MessageConverter)
- Method in class org.springframework.integration.amqp.inbound.
AmqpInboundChannelAdapter
setMessageConverter(MessageConverter)
- Method in class org.springframework.integration.amqp.inbound.
AmqpInboundGateway
setMessagePropertiesConverter(MessagePropertiesConverter)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setPhase(int)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setPrefetchCount(int)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setPubSub(boolean)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setQueueName(String)
- Method in class org.springframework.integration.amqp.channel.
PointToPointSubscribableAmqpChannel
Provide a Queue name to be used.
setQueueName(String)
- Method in class org.springframework.integration.amqp.channel.
PollableAmqpChannel
Provide an explicitly configured queue name.
setQueueName(String)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
Set the Queue name to use.
setReceiveTimeout(long)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setRecoveryInterval(long)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setReturnChannel(MessageChannel)
- Method in class org.springframework.integration.amqp.outbound.
AmqpOutboundEndpoint
setRoutingKey(String)
- Method in class org.springframework.integration.amqp.outbound.
AmqpOutboundEndpoint
setRoutingKeyExpression(String)
- Method in class org.springframework.integration.amqp.outbound.
AmqpOutboundEndpoint
setShutdownTimeout(long)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setTaskExecutor(Executor)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setTransactionAttribute(TransactionAttribute)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setTransactionManager(PlatformTransactionManager)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
setTxSize(int)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
SPRING_REPLY_CORRELATION
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
SPRING_REPLY_TO_STACK
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
start()
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
stop()
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
stop(Runnable)
- Method in class org.springframework.integration.amqp.config.
AmqpChannelFactoryBean
T
TIMESTAMP
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
TYPE
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
U
USER_ID
- Static variable in class org.springframework.integration.amqp.
AmqpHeaders
A
B
C
D
E
G
H
I
M
O
P
R
S
T
U
Overview
Package
Class
Tree
Deprecated
Index
Help
PREV NEXT
FRAMES
NO FRAMES
All Classes