Spring AMQP
		Next

Spring AMQP

Authors

Mark Pollack , Mark Fisher , Oleg Zhurakousky , Dave Syer , Gary Russell , Gunnar Hillert , Artem Bilan , Stéphane Nicoll

1.5.0.RC1

Copyright © 2010-2015 Pivotal Software Inc.

Copies of this document may be made for your own use and for distribution to others, provided that you do not charge any fee for such copies and further provided that each copy contains this Copyright Notice, whether distributed in print or electronically.

Table of Contents

2. Introduction

2.1. Quick Tour for the impatient

2.1.1. Introduction

Compatibility
Very, Very Quick
With XML Configuration
With Java Configuration

2.2. What’s New

2.2.1. Changes in 1.5 Since 1.4

spring-erlang is No Longer Supported
CachingConnectionFactory Changes
Properties to Control Container Queue Declaration Behavior
Class Package Change
DefaultMessagePropertiesConverter
@RabbitListener Improvements
Automatic Exchange, Queue, Binding Declaration
RabbitTemplate Changes
The RabbitManagementTemplate
Listener Container Bean Names (XML)
Class-Level @RabbitListener
SimpleMessageListenerContainer: BackOff support
Channel Close Logging
Application Events
Consumer Tag Configuration
MessageListenerAdapter
LocalizedQueueConnectionFactory

2.2.2. Changes in 1.4 Since 1.3

@RabbitListener Annotation
RabbitMessagingTemplate
Listener Container Missing Queues Fatal Attribute
RabbitTemplate ConfirmCallback Interface
RabbitConnectionFactoryBean
CachingConnectionFactory
Log Appender
Listener Queues
RabbitTemplate: mandatory and connectionFactorySelector Expressions
Listeners and the Routing Connection Factory
RabbitTemplate: RecoveryCallback option
MessageConversionException
RabbitMQ 3.4 Compatibility
ContentTypeDelegatingMessageConverter

2.2.3. Changes in 1.3 Since 1.2

Listener Concurrency
Listener Queues
Consumer Priority
Exclusive Consumer
Rabbit Admin
Direct Exchange Binding
AMQP Template
Caching Connection Factory
Binding Arguments
Routing Connection Factory
MessageBuilder and MessagePropertiesBuilder
RetryInterceptorBuilder
RepublishMessageRecoverer
Default Error Handler (Since 1.3.2)
Listener Container 'missingQueuesFatal` Property (Since 1.3.5)

2.2.4. Changes to 1.2 Since 1.1

RabbitMQ Version
Rabbit Admin
Rabbit Template
JSON Message Converters
Automatic Declaration of Queues, etc
AMQP Remoting
Requested Heart Beats

2.2.5. Changes to 1.1 Since 1.0

General
AMQP Log4j Appender

3. Reference

3.1. Using Spring AMQP

3.1.1. AMQP Abstractions

Introduction
Message
Exchange
Queue
Binding

3.1.2. Connection and Resource Management

Introduction
Configuring the Underlying Client Connection Factory
Configuring SSL
Routing Connection Factory
Queue Affinity and the LocalizedQueueConnectionFactory
Publisher Confirms and Returns
Logging Channel Close Events

3.1.3. AmqpTemplate

Introduction
Adding Retry Capabilities
Publisher Confirms and Returns
Messaging integration

3.1.4. Sending messages

Introduction
Message Builder API
Publisher Returns
Batching

3.1.5. Receiving messages

Introduction
Polling Consumer
Asynchronous Consumer
Batched Messages
Consumer Failure Events

3.1.6. Consumer Tags

Annotation-driven Listener Endpoints
Threading and Asynchronous Consumers

3.1.7. Message Converters

Introduction
SimpleMessageConverter
JsonMessageConverter and Jackson2JsonMessageConverter
MarshallingMessageConverter
ContentTypeDelegatingMessageConverter
Message Properties Converters

3.1.8. Modifying Messages - Compression and More

3.1.9. Request/Reply Messaging

Introduction
Reply Timeout
RabbitMQ Direct reply-to
Message Correlation With A Reply Queue
Reply Listener Container
Spring Remoting with AMQP

3.1.10. Configuring the broker

Introduction
Declaring Collections of Exchanges, Queues, Bindings
Conditional Declaration

3.1.11. RabbitMQ REST API

3.1.12. Exception Handling

3.1.13. Transactions

Introduction
A note on Rollback of Received Messages
Using the RabbitTransactionManager

3.1.14. Message Listener Container Configuration

3.1.15. Listener Concurrency

3.1.16. Exclusive Consumer

3.1.17. Listener Container Queues

3.1.18. Resilience: Recovering from Errors and Broker Failures

Introduction
Automatic Declaration of Exchanges, Queues and Bindings
Failures in Synchronous Operations and Options for Retry
Message Listeners and the Asynchronous Case
Exception Classification for Retry

3.1.19. Debugging

3.2. Sample Applications

3.2.1. Introduction

3.2.2. Hello World

Introduction
Synchronous Example
Asynchronous Example

3.2.3. Stock Trading

4. Spring Integration - Reference

4.1. Spring Integration AMQP Support

4.1.1. Introduction
4.1.2. Inbound Channel Adapter
4.1.3. Outbound Channel Adapter
4.1.4. Inbound Gateway
4.1.5. Outbound Gateway

5. Other Resources

5.1. Further Reading

		Next
		1. Preface