Spring Integration Reference Manual V5.1.1.RELEASE Mark Fisher
User Manual:
Open the PDF directly: View PDF
Page Count: 712 [warning: Documents this large are best viewed by clicking the View PDF Link!]
- Spring Integration Reference Manual
- Table of Contents
- Part I. Preface
- Part II. What’s New?
- 4. What’s New in Spring Integration 5.1?
- 4.1 New Components
- 4.2 General Changes
- 4.3 Files Changes
- 4.4 AMQP Changes
- 4.5 JDBC Changes
- 4.6 FTP and SFTP Changes
- 4.7 TCP Support
- 4.8 Twitter Support
- 4.9 JMS Support
- 4.10 HTTP/WebFlux Support
- 4.11 JMX Changes
- 4.12 Micrometer Support Changes
- 4.13 Integration Graph Customization
- 4.14 Integration Global Properties
- 4.15 The receiveTimeout for @Poller
- 4. What’s New in Spring Integration 5.1?
- Part III. Overview of Spring Integration Framework
- Part IV. Core Messaging
- 6. Messaging Channels
- 6.1 Message Channels
- The MessageChannel Interface
- Message Channel Implementations
- Channel Interceptors
- MessagingTemplate
- Configuring Message Channels
- DirectChannel Configuration
- Datatype Channel Configuration
- QueueChannel Configuration
- PublishSubscribeChannel Configuration
- ExecutorChannel
- PriorityChannel Configuration
- RendezvousChannel Configuration
- Scoped Channel Configuration
- Channel Interceptor Configuration
- Global Channel Interceptor Configuration
- Wire Tap
- Conditional Wire Taps
- Global Wire Tap Configuration
- Special Channels
- 6.2 Poller
- 6.3 Channel Adapter
- 6.4 Messaging Bridge
- 6.1 Message Channels
- 7. Message
- 8. Message Routing
- 8.1 Routers
- 8.2 Filter
- 8.3 Splitter
- 8.4 Aggregator
- 8.5 Resequencer
- 8.6 Message Handler Chain
- 8.7 Scatter-Gather
- 8.8 Thread Barrier
- 9. Message Transformation
- 10. Messaging Endpoints
- 10.1 Message Endpoints
- 10.2 Endpoint Roles
- 10.3 Leadership Event Handling
- 10.4 Messaging Gateways
- Enter the GatewayProxyFactoryBean
- Gateway XML Namespace Support
- Setting the Default Reply Channel
- Gateway Configuration with Annotations and XML
- Mapping Method Arguments to a Message
- @MessagingGateway Annotation
- Invoking No-Argument Methods
- Error Handling
- Gateway Timeouts
- Asynchronous Gateway
- Gateway Behavior When No response Arrives
- 10.5 Service Activator
- 10.6 Delayer
- 10.7 Scripting Support
- 10.8 Groovy support
- 10.9 Adding Behavior to Endpoints
- 10.10 Logging Channel Adapter
- 10.11 java.util.function Interfaces Support
- 11. Java DSL
- 11.1 DSL Basics
- 11.2 Message Channels
- 11.3 Pollers
- 11.4 DSL and Endpoint Configuration
- 11.5 Transformers
- 11.6 Inbound Channel Adapters
- 11.7 Message Routers
- 11.8 Splitters
- 11.9 Aggregators and Resequencers
- 11.10 Service Activators and the .handle() method
- 11.11 Operator log()
- 11.12 MessageChannelSpec.wireTap()
- 11.13 Working With Message Flows
- 11.14 FunctionExpression
- 11.15 Sub-flows support
- 11.16 Using Protocol Adapters
- 11.17 IntegrationFlowAdapter
- 11.18 Dynamic and Runtime Integration Flows
- 11.19 IntegrationFlow as Gateway
- 12. System Management
- 6. Messaging Channels
- Part V. Integration Endpoints
- 13. Endpoint Quick Reference Table
- 14. AMQP Support
- 14.1 Inbound Channel Adapter
- 14.2 Polled Inbound Channel Adapter
- 14.3 Inbound Gateway
- 14.4 Inbound Endpoint Acknowledge Mode
- 14.5 Outbound Channel Adapter
- 14.6 Outbound Gateway
- 14.7 Asynchronous Outbound Gateway
- 14.8 Outbound Message Conversion
- 14.9 Outbound User ID
- 14.10 Delayed Message Exchange
- 14.11 AMQP-backed Message Channels
- 14.12 AMQP Message Headers
- 14.13 Strict Message Ordering
- 14.14 AMQP Samples
- 15. Spring ApplicationEvent Support
- 16. Feed Adapter
- 17. File Support
- 17.1 Reading Files
- 17.2 Writing files
- 17.3 File Transformers
- 17.4 File Splitter
- 18. FTP/FTPS Adapters
- 18.1 FTP Session Factory
- 18.2 Advanced Configuration
- 18.3 Delegating Session Factory
- 18.4 FTP Inbound Channel Adapter
- 18.5 FTP Streaming Inbound Channel Adapter
- 18.6 Inbound Channel Adapters: Polling Multiple Servers and Directories
- 18.7 Inbound Channel Adapters: Controlling Remote File Fetching
- 18.8 FTP Outbound Channel Adapter
- 18.9 FTP Outbound Gateway
- Using the ls Command
- Using the nlst Command
- Using the get Command
- Using the mget Command
- Using the put Command
- Using the rm Command
- Using the mv Command
- Additional Information about FTP Outbound Gateway Commands
- Configuring with Java Configuration
- Configuring with the Java DSL
- Outbound Gateway Partial Success (mget and mput)
- 18.10 FTP Session Caching
- 18.11 Using RemoteFileTemplate
- 18.12 Using MessageSessionCallback
- 19. Pivotal GemFire and Apache Geode Support
- 20. HTTP Support
- 21. JDBC Support
- 22. JPA Support
- 22.1 Functionality
- 22.2 Supported Persistence Providers
- 22.3 Java Implementation
- 22.4 Namespace Support
- 22.5 Inbound Channel Adapter
- 22.6 Outbound Channel Adapter
- 22.7 Outbound Gateways
- 23. JMS Support
- 23.1 Inbound Channel Adapter
- 23.2 Message-driven Channel Adapter
- 23.3 Outbound Channel Adapter
- 23.4 Inbound Gateway
- 23.5 Outbound Gateway
- 23.6 Mapping Message Headers to and from JMS Message
- 23.7 Message Conversion, Marshalling, and Unmarshalling
- 23.8 JMS-backed Message Channels
- 23.9 Using JMS Message Selectors
- 23.10 JMS Samples
- 24. Mail Support
- 25. MongoDb Support
- 26. MQTT Support
- 27. Redis Support
- 27.1 Connecting to Redis
- 27.2 Messaging with Redis
- 27.3 Redis Message Store
- 27.4 Redis Metadata Store
- 27.5 Redis Store Inbound Channel Adapter
- 27.6 RedisStore Outbound Channel Adapter
- 27.7 Redis Outbound Command Gateway
- 27.8 Redis Queue Outbound Gateway
- 27.9 Redis Queue Inbound Gateway
- 27.10 Redis Lock Registry
- 28. Resource Support
- 29. RMI Support
- 30. SFTP Adapters
- 30.1 SFTP Session Factory
- 30.2 Proxy Factory Bean
- 30.3 Delegating Session Factory
- 30.4 SFTP Session Caching
- 30.5 Using RemoteFileTemplate
- 30.6 SFTP Inbound Channel Adapter
- 30.7 SFTP Streaming Inbound Channel Adapter
- 30.8 Inbound Channel Adapters: Polling Multiple Servers and Directories
- 30.9 Inbound Channel Adapters: Controlling Remote File Fetching
- 30.10 SFTP Outbound Channel Adapter
- 30.11 SFTP Outbound Gateway
- 30.12 SFTP/JSCH Logging
- 30.13 MessageSessionCallback
- 31. STOMP Support
- 32. Stream Support
- 33. Syslog Support
- 34. TCP and UDP Support
- 34.1 Introduction
- 34.2 UDP Adapters
- Outbound UDP Adapters (XML Configuration)
- Outbound UDP Adapters (Java Configuration)
- Outbound UDP Adapters (Java DSL Configuration)
- Inbound UDP Adapters (XML Configuration)
- Inbound UDP Adapters (Java Configuration)
- Inbound UDP Adapters (Java DSL Configuration)
- Server Listening Events
- Advanced Outbound Configuration
- 34.3 TCP Connection Factories
- 34.4 TCP Connection Interceptors
- 34.5 TCP Connection Events
- 34.6 TCP Adapters
- 34.7 TCP Gateways
- 34.8 TCP Message Correlation
- 34.9 About Non-blocking I/O (NIO)
- 34.10 SSL/TLS Support
- 34.11 Advanced Techniques
- 34.12 IP Configuration Attributes
- 34.13 IP Message Headers
- 34.14 Annotation-Based Configuration
- 35. WebFlux Support
- 36. WebSockets Support
- 37. Web Services Support
- 38. XML Support - Dealing with XML Payloads
- 38.1 Namespace Support
- 38.2 Transforming XML Payloads
- 38.3 Transforming XML Messages with XPath
- 38.4 Splitting XML Messages
- 38.5 Routing XML Messages with XPath
- 38.6 XPath Header Enricher
- 38.7 Using the XPath Filter
- 38.8 #xpath SpEL Function
- 38.9 XML Validating Filter
- 39. XMPP Support
- 40. Zookeeper Support
- Part VI. Appendices
- Appendix A. Spring Expression Language (SpEL)
- Appendix B. Message Publishing
- Appendix C. Transaction Support
- Appendix D. Security in Spring Integration
- Appendix E. Configuration
- Appendix F. Testing support
- Appendix G. Spring Integration Samples
- Appendix H. Additional Resources
- Appendix I. Change History
- I.1 Changes between 4.3 and 5.0
- I.2 New Components
- I.3 General Changes
- Core Changes
- Gateway Changes
- Aggregator Performance Changes
- Splitter Changes
- JMS Changes
- Mail Changes
- Feed Changes
- File Changes
- FTP and SFTP Changes
- Integration Properties
- Stream Changes
- Barrier Changes
- AMQP Changes
- HTTP Changes
- MQTT Changes
- STOMP Changes
- Web Services Changes
- Redis Changes
- TCP Changes
- Gemfire Changes
- JDBC Changes
- Metrics Changes
- @EndpointId Annotations
- I.4 Changes between 4.2 and 4.3
- I.5 New Components
- I.6 General Changes
- Core Changes
- Mail Changes
- JMS Changes
- Aggregator Changes
- TCP/UDP Changes
- File Changes
- AMQP Changes
- Redis Changes
- HTTP Changes
- SFTP Changes
- FTP Changes
- Router Changes
- Header Mapping
- Groovy Scripts
- @InboundChannelAdapter Changes
- XMPP Changes
- WireTap Late Binding
- ChannelMessageStoreQueryProvider Changes
- WebSocket Changes
- I.7 Changes between 4.1 and 4.2
- I.8 New Components
- I.9 General Changes
- I.10 Changes between 4.0 and 4.1
- New Components
- General Changes
- AMQP Inbound Endpoints, Channel
- AMQP Outbound Endpoints
- SimpleMessageStore
- Web Service Outbound Gateway: encode-uri
- Http Inbound Channel Adapter and Status Code
- MQTT Adapter Changes
- FTP and SFTP Adapter Changes
- Splitter and Iterator
- Aggregator
- Content Enricher Improvements
- Header Channel Registry
- Orderly Shutdown
- Management for RecipientListRouter
- AbstractHeaderMapper: NON_STANDARD_HEADERS token
- AMQP Channels: template-channel-transacted
- Syslog Adapter
- Asynchronous Gateway
- Aggregator Advice Chain
- Outbound Channel Adapter and Scripts
- Resequencer Changes
- Optional POJO method parameter
- QueueChannel backed Queue type
- ChannelInterceptor Changes
- IMAP PEEK
- I.11 Changes between 3.0 and 4.0
- New Components
- MQTT Channel Adapters
- @EnableIntegration
- @IntegrationComponentScan
- "@EnableMessageHistory"
- @MessagingGateway
- Spring Boot @EnableAutoConfiguration
- @GlobalChannelInterceptor
- @IntegrationConverter
- @EnablePublisher
- Redis Channel Message Stores
- MongodDB Channel Message Store
- @EnableIntegrationMBeanExport
- ChannelSecurityInterceptorFactoryBean
- Redis Command Gateway
- RedisLockRegistry and GemfireLockRegistry
- @Poller
- @InboundChannelAdapter and SmartLifecycle for Annotated Endpoints
- Twitter Search Outbound Gateway
- Gemfire Metadata Store
- @BridgeFrom and @BridgeTo Annotations
- Meta-messaging Annotations
- General Changes
- Requires Spring Framework 4.0
- Header Type for XPath Header Enricher
- Object To JSON Transformer: Node Result
- JMS Header Mapping
- JMS Outbound Channel Adapter
- JMS Inbound Channel Adapter
- Datatype Channels
- Simpler Retry Advice Configuration
- Correlation Endpoint: Time-based Release Strategy
- Redis Metadata Store
- JdbcChannelMessageStore and PriorityChannel
- AMQP Endpoints Delivery Mode
- FTP Timeouts
- Twitter: StatusUpdatingMessageHandler
- JPA Retrieving Gateway: id-expression
- TCP Deserialization Events
- Messaging Annotations on @Bean Definitions
- New Components
- I.12 Changes Between 2.2 and 3.0
- New Components
- HTTP Request Mapping
- Spring Expression Language (SpEL) Configuration
- SpEL Functions Support
- SpEL PropertyAccessors Support
- Redis: New Components
- Header Channel Registry
- MongoDB support: New ConfigurableMongoDbMessageStore
- Syslog Support
- tail Support
- JMX Support
- TCP/IP Connection Events and Connection Management
- Inbound Channel Adapter Script Support
- Content Enricher: Headers Enrichment Support
- General Changes
- Message ID Generation
- "<gateway>" Changes
- HTTP Endpoint Changes
- Jackson Support (JSON)
- Chain Elements id Attribute
- Aggregator empty-group-min-timeout property
- Persistent File List Filters (file, (S)FTP)
- Scripting Support: Variables Changes
- Direct Channel Load Balancing configuration
- PublishSubscribeChannel Behavior
- FTP, SFTP and FTPS Changes
- requires-reply Attribute for Outbound Gateways
- AMQP Outbound Gateway Header Mapping
- Stored Procedure Components Improvements
- Web Service Outbound URI Configuration
- Redis Adapter Changes
- Advising Filters
- Advising Endpoints using Annotations
- ObjectToStringTransformer Improvements
- JPA Support Changes
- Delayer: delay expression
- JDBC Message Store Improvements
- IMAP Idle Connection Exceptions
- Message Headers and TCP
- JMS Message Driven Channel Adapter
- RMI Inbound Gateway
- XsltPayloadTransformer
- New Components
- I.13 Changes between 2.1 and 2.2
- New Components
- General Changes
- Spring 3.1 Used by Default
- Adding Behavior to Endpoints
- Transaction Synchronization and Pseudo Transactions
- File Adapter: Improved File Overwrite and Append Handling
- Reply-Timeout Added to More Outbound Gateways
- Spring-AMQP 1.1
- JDBC Support - Stored Procedures Components
- JDBC Support: Outbound Gateway
- JDBC Support: Channel-specific Message Store Implementation
- Orderly Shutdown
- JMS Outbound Gateway Improvements
- ObjectToJsonTransformer
- HTTP Support
- I.14 Changes between 2.0 and 2.1
- I.15 Changes between Versions 1.0 and 2.0