diff --git a/advanced/advanced-testing-examples/pom.xml b/advanced/advanced-testing-examples/pom.xml
index e73a8752..50a19617 100644
--- a/advanced/advanced-testing-examples/pom.xml
+++ b/advanced/advanced-testing-examples/pom.xml
@@ -171,14 +171,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/advanced/dynamic-ftp/pom.xml b/advanced/dynamic-ftp/pom.xml
index 93695e13..25731cab 100644
--- a/advanced/dynamic-ftp/pom.xml
+++ b/advanced/dynamic-ftp/pom.xml
@@ -148,14 +148,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/advanced/dynamic-tcp-client/pom.xml b/advanced/dynamic-tcp-client/pom.xml
index 159a9593..eaca4203 100644
--- a/advanced/dynamic-tcp-client/pom.xml
+++ b/advanced/dynamic-tcp-client/pom.xml
@@ -178,14 +178,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/applications/cafe-scripted/pom.xml b/applications/cafe-scripted/pom.xml
index 4dab7cdd..1c2f4e5b 100644
--- a/applications/cafe-scripted/pom.xml
+++ b/applications/cafe-scripted/pom.xml
@@ -217,14 +217,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/applications/cafe/cafe-amqp/pom.xml b/applications/cafe/cafe-amqp/pom.xml
index a4f110c9..dd9ee655 100644
--- a/applications/cafe/cafe-amqp/pom.xml
+++ b/applications/cafe/cafe-amqp/pom.xml
@@ -160,14 +160,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/applications/cafe/cafe-jms/pom.xml b/applications/cafe/cafe-jms/pom.xml
index 5a34908e..a6213c82 100644
--- a/applications/cafe/cafe-jms/pom.xml
+++ b/applications/cafe/cafe-jms/pom.xml
@@ -200,14 +200,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/applications/cafe/cafe-si/pom.xml b/applications/cafe/cafe-si/pom.xml
index df37adf2..a52f212e 100644
--- a/applications/cafe/cafe-si/pom.xml
+++ b/applications/cafe/cafe-si/pom.xml
@@ -160,14 +160,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/applications/file-split-ftp/pom.xml b/applications/file-split-ftp/pom.xml
index 48f505cc..dc2f037e 100644
--- a/applications/file-split-ftp/pom.xml
+++ b/applications/file-split-ftp/pom.xml
@@ -246,14 +246,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/applications/loan-broker/pom.xml b/applications/loan-broker/pom.xml
index 034b01c9..48d87430 100644
--- a/applications/loan-broker/pom.xml
+++ b/applications/loan-broker/pom.xml
@@ -148,14 +148,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/applications/loanshark/pom.xml b/applications/loanshark/pom.xml
index 5a2e5df5..b907381f 100644
--- a/applications/loanshark/pom.xml
+++ b/applications/loanshark/pom.xml
@@ -441,14 +441,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/applications/stomp-chat/pom.xml b/applications/stomp-chat/pom.xml
index e354f9fd..1eaa3044 100644
--- a/applications/stomp-chat/pom.xml
+++ b/applications/stomp-chat/pom.xml
@@ -200,14 +200,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/amqp/pom.xml b/basic/amqp/pom.xml
index 550aeb73..5c5a2724 100644
--- a/basic/amqp/pom.xml
+++ b/basic/amqp/pom.xml
@@ -171,14 +171,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/barrier/pom.xml b/basic/barrier/pom.xml
index 6205aa90..796c5b51 100644
--- a/basic/barrier/pom.xml
+++ b/basic/barrier/pom.xml
@@ -211,14 +211,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/control-bus/pom.xml b/basic/control-bus/pom.xml
index 6f0a2177..5ffa5666 100644
--- a/basic/control-bus/pom.xml
+++ b/basic/control-bus/pom.xml
@@ -148,14 +148,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/enricher/pom.xml b/basic/enricher/pom.xml
index 99e0d21f..433edccd 100644
--- a/basic/enricher/pom.xml
+++ b/basic/enricher/pom.xml
@@ -160,14 +160,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/feed/pom.xml b/basic/feed/pom.xml
index 2164331f..0a10efa5 100644
--- a/basic/feed/pom.xml
+++ b/basic/feed/pom.xml
@@ -148,14 +148,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/file/pom.xml b/basic/file/pom.xml
index 69c508f8..9b58b808 100644
--- a/basic/file/pom.xml
+++ b/basic/file/pom.xml
@@ -148,14 +148,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/ftp/pom.xml b/basic/ftp/pom.xml
index 1d964c0b..0e45652b 100644
--- a/basic/ftp/pom.xml
+++ b/basic/ftp/pom.xml
@@ -207,14 +207,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/helloworld/pom.xml b/basic/helloworld/pom.xml
index 21752079..566cbe3c 100644
--- a/basic/helloworld/pom.xml
+++ b/basic/helloworld/pom.xml
@@ -148,14 +148,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/http/pom.xml b/basic/http/pom.xml
index ce181ace..72fdebaf 100644
--- a/basic/http/pom.xml
+++ b/basic/http/pom.xml
@@ -218,14 +218,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/jdbc/pom.xml b/basic/jdbc/pom.xml
index cf150f7e..29e20d79 100644
--- a/basic/jdbc/pom.xml
+++ b/basic/jdbc/pom.xml
@@ -160,14 +160,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/jms/pom.xml b/basic/jms/pom.xml
index 79971abc..e229a15d 100644
--- a/basic/jms/pom.xml
+++ b/basic/jms/pom.xml
@@ -210,14 +210,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/jmx/pom.xml b/basic/jmx/pom.xml
index f499a055..d633e8ab 100644
--- a/basic/jmx/pom.xml
+++ b/basic/jmx/pom.xml
@@ -159,14 +159,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/jpa/pom.xml b/basic/jpa/pom.xml
index ad652342..ab4d649e 100644
--- a/basic/jpa/pom.xml
+++ b/basic/jpa/pom.xml
@@ -213,14 +213,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/kafka/pom.xml b/basic/kafka/pom.xml
index a09383a6..6ec03f18 100644
--- a/basic/kafka/pom.xml
+++ b/basic/kafka/pom.xml
@@ -71,7 +71,7 @@
org.springframework.integration
spring-integration-kafka
- 3.2.0.BUILD-SNAPSHOT
+ 3.2.0.M1
compile
@@ -98,7 +98,7 @@
org.springframework.kafka
spring-kafka
- 2.3.0.BUILD-SNAPSHOT
+ 2.3.0.M1
compile
@@ -218,14 +218,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/mail/pom.xml b/basic/mail/pom.xml
index 8f1a685c..e96e7e78 100644
--- a/basic/mail/pom.xml
+++ b/basic/mail/pom.xml
@@ -183,14 +183,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/mongodb/pom.xml b/basic/mongodb/pom.xml
index a1c2b868..acea9836 100644
--- a/basic/mongodb/pom.xml
+++ b/basic/mongodb/pom.xml
@@ -148,14 +148,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/mqtt/pom.xml b/basic/mqtt/pom.xml
index 0384ece0..7ad1f077 100644
--- a/basic/mqtt/pom.xml
+++ b/basic/mqtt/pom.xml
@@ -200,14 +200,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/oddeven/pom.xml b/basic/oddeven/pom.xml
index 0b05170e..b30d37e9 100644
--- a/basic/oddeven/pom.xml
+++ b/basic/oddeven/pom.xml
@@ -148,14 +148,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/quote/pom.xml b/basic/quote/pom.xml
index f5a63ef5..0611582c 100644
--- a/basic/quote/pom.xml
+++ b/basic/quote/pom.xml
@@ -148,14 +148,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/sftp/pom.xml b/basic/sftp/pom.xml
index 67478e77..9d98e76a 100644
--- a/basic/sftp/pom.xml
+++ b/basic/sftp/pom.xml
@@ -160,14 +160,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/splunk/pom.xml b/basic/splunk/pom.xml
index d54ab4bb..0bf659ff 100644
--- a/basic/splunk/pom.xml
+++ b/basic/splunk/pom.xml
@@ -190,14 +190,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/tcp-amqp/pom.xml b/basic/tcp-amqp/pom.xml
index 7c371250..691e786d 100644
--- a/basic/tcp-amqp/pom.xml
+++ b/basic/tcp-amqp/pom.xml
@@ -183,14 +183,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/tcp-broadcast/pom.xml b/basic/tcp-broadcast/pom.xml
index 072b2c04..d7199e8e 100644
--- a/basic/tcp-broadcast/pom.xml
+++ b/basic/tcp-broadcast/pom.xml
@@ -189,14 +189,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/tcp-client-server/pom.xml b/basic/tcp-client-server/pom.xml
index a2aa549a..70cdca17 100644
--- a/basic/tcp-client-server/pom.xml
+++ b/basic/tcp-client-server/pom.xml
@@ -171,14 +171,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/tcp-with-headers/pom.xml b/basic/tcp-with-headers/pom.xml
index 65cf6382..42c2f2ba 100644
--- a/basic/tcp-with-headers/pom.xml
+++ b/basic/tcp-with-headers/pom.xml
@@ -190,14 +190,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/testing-examples/pom.xml b/basic/testing-examples/pom.xml
index 47d6e10c..a46bcb00 100644
--- a/basic/testing-examples/pom.xml
+++ b/basic/testing-examples/pom.xml
@@ -192,14 +192,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/twitter/pom.xml b/basic/twitter/pom.xml
index e919a908..8471a8ce 100644
--- a/basic/twitter/pom.xml
+++ b/basic/twitter/pom.xml
@@ -149,14 +149,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/web-sockets/pom.xml b/basic/web-sockets/pom.xml
index 8b3421e7..aed2ba96 100644
--- a/basic/web-sockets/pom.xml
+++ b/basic/web-sockets/pom.xml
@@ -178,14 +178,14 @@
org.springframework
spring-framework-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
org.springframework.integration
spring-integration-bom
- 5.2.0.BUILD-SNAPSHOT
+ 5.2.0.M1
import
pom
diff --git a/basic/web-sockets/src/main/java/org/springframework/integration/samples/websocket/standard/server/Application.java b/basic/web-sockets/src/main/java/org/springframework/integration/samples/websocket/standard/server/Application.java
index df8189f2..f5c6e96d 100644
--- a/basic/web-sockets/src/main/java/org/springframework/integration/samples/websocket/standard/server/Application.java
+++ b/basic/web-sockets/src/main/java/org/springframework/integration/samples/websocket/standard/server/Application.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2014 the original author or authors.
+ * Copyright 2014-2019 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -19,7 +19,6 @@ package org.springframework.integration.samples.websocket.standard.server;
import java.text.DateFormat;
import java.util.Collections;
import java.util.Date;
-import java.util.Iterator;
import java.util.concurrent.Executors;
import org.springframework.boot.SpringApplication;
@@ -42,7 +41,6 @@ import org.springframework.integration.transformer.HeaderEnricher;
import org.springframework.integration.transformer.support.ExpressionEvaluatingHeaderValueMessageProcessor;
import org.springframework.integration.websocket.ServerWebSocketContainer;
import org.springframework.integration.websocket.outbound.WebSocketOutboundMessageHandler;
-import org.springframework.messaging.Message;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.MessageHandler;
import org.springframework.messaging.simp.SimpMessageHeaderAccessor;
@@ -50,6 +48,7 @@ import org.springframework.messaging.support.GenericMessage;
/**
* @author Artem Bilan
+ *
* @since 3.0
*/
@Configuration
@@ -71,14 +70,7 @@ public class Application {
@Bean
@InboundChannelAdapter(value = "splitChannel", poller = @Poller(fixedDelay = "1000", maxMessagesPerPoll = "1"))
public MessageSource> webSocketSessionsMessageSource() {
- return new MessageSource>() {
-
- @Override
- public Message> receive() {
- return new GenericMessage>(serverWebSocketContainer().getSessions().keySet().iterator());
- }
-
- };
+ return () -> new GenericMessage<>(serverWebSocketContainer().getSessions().keySet().iterator());
}
@Bean
@@ -103,15 +95,16 @@ public class Application {
@Transformer(inputChannel = "headerEnricherChannel", outputChannel = "transformChannel")
public HeaderEnricher headerEnricher() {
return new HeaderEnricher(Collections.singletonMap(SimpMessageHeaderAccessor.SESSION_ID_HEADER,
- new ExpressionEvaluatingHeaderValueMessageProcessor