4. What’s New in Spring Integration 5.1?

This chapter provides an overview of the new features and improvements that have been introduced with Spring Integration 5.1. If you are interested in more details, see the Issue Tracker tickets that were resolved as part of the 5.1 development process.

4.1 New Components

The following components are new in 5.1:

4.1.1 AmqpDedicatedChannelAdvice

See Section 14.13, “Strict Message Ordering”.

4.2 General Changes

The following changes have been made in version 5.1:

4.2.1 Java DSL

The IntegrationFlowContext is now an interface and IntegrationFlowRegistration is an inner interface of IntegrationFlowContext.

4.2.2 Dispatcher Exceptions

Exceptions caught and re-thrown by AbstractDispatcher are now more consistent:

  • A MessagingException of any kind that has a failedMessage property is re-thrown unchanged.
  • All other exceptions are wrapped in a MessageDeliveryException with the failedMessage property set.

Previously:

  • A MessagingException of any kind that has a failedMessage property was re-thrown unchanged
  • A MessagingException that had no failedMessage property was wrapped in a MessagingException with the failedMessage property set.
  • Other RuntimeException instances were re-thrown unchanged.
  • Checked exceptions were wrapped in a MessageDeliveryException with the failedMessage property set.

4.2.3 Global Channel Interceptors

Global channel interceptors now apply to dynamically registered channels, such as through the IntegrationFlowContext when using the Java DSL or beans that are initialized using beanFactory.initializeBean(). Previously, when beans were created after the application context was refreshed, interceptors were not applied.

4.2.4 ObjectToJsonTransformer

A new ResultType.BYTES mode is introduced for the ObjectToJsonTransformer.

See the section called “JSON Transformers” for more information.

4.2.5 Integration Flows: Generated Bean Names

Starting with version 5.0.5, generated bean names for the components in an IntegrationFlow include the flow bean name, followed by a dot, as a prefix. For example, if a flow bean were named flowBean, a generated bean might be named flowBean.generatedBean.

See Section 11.13, “Working With Message Flows” for more information.

4.2.6 Aggregator Changes

If the groupTimeout is evaluated to a negative value, an aggregator now expires the group immediately. Only null is considered as a signal to do nothing for the current message.

See Section 8.4, “Aggregator” for more information.

4.2.7 @Publisher annotation changes

Starting with version 5.1, you must explicitly turn on the @Publisher AOP functionality by using @EnablePublisher or by using the <int:enable-publisher> child element on <int:annotation-config>.

See Section B.1.1, “Annotation-driven Configuration with the @Publisher Annotation” for more information.

4.3 Files Changes

If you are using FileExistsMode.APPEND or FileExistsMode.APPEND_NO_FLUSH you can provide a newFileCallback that will be called when creating a new file. This callback receives the newly created file and the message that triggered the callback. This could be used to write a CSV header, for an example.

See Chapter 17, File Support for more information.

4.4 AMQP Changes

We have made ID and Timestamp header mapping changes in the DefaultAmqpHeaderMapper. See the note near the bottom of Section 14.12, “AMQP Message Headers” for more information.

The contentType header is now correctly mapped as an entry in the general headers map. See Section 14.12.2, “contentType Header” for more information.

4.5 JDBC Changes

A confusing max-rows-per-poll property on the JDBC Inbound Channel Adapter and JDBC Outbound Gateway has been deprecated in favor of the newly introduced max-rows property.

See Chapter 21, JDBC Support for more information.

4.6 FTP and SFTP Changes

A RotatingServerAdvice is now available to poll multiple servers and directories with the inbound channel adapters. See Section 18.6, “Inbound Channel Adapters: Polling Multiple Servers and Directories” and Section 30.8, “Inbound Channel Adapters: Polling Multiple Servers and Directories” for more information.

Also, inbound adapter localFilenameExpression instances can contain the #remoteDirectory variable, which contains the remote directory being polled. The generic type of the comparators (used to sort the fetched file list for the streaming adapters) has changed from Comparator<AbstractFileInfo<F>> to Comparator<F>. See Section 18.5, “FTP Streaming Inbound Channel Adapter” and Section 30.7, “SFTP Streaming Inbound Channel Adapter” for more information.

In addition, the synchronizers for inbound channel adapters can now be provided with a Comparator. This is useful when using maxFetchSize to limit the files retrieved.

4.7 Twitter Support

Since the Spring Social project has moved to end of life status, Twitter support in Spring Integration has been moved to the Extensions project. See Spring Integration Social Twitter for more information.