diff --git a/spring-integration-core/src/main/java/org/springframework/integration/aggregator/AbstractCorrelatingMessageHandler.java b/spring-integration-core/src/main/java/org/springframework/integration/aggregator/AbstractCorrelatingMessageHandler.java
index 13643b6143..70461f4007 100644
--- a/spring-integration-core/src/main/java/org/springframework/integration/aggregator/AbstractCorrelatingMessageHandler.java
+++ b/spring-integration-core/src/main/java/org/springframework/integration/aggregator/AbstractCorrelatingMessageHandler.java
@@ -733,6 +733,10 @@ public abstract class AbstractCorrelatingMessageHandler extends AbstractMessageP
private class ForceReleaseMessageGroupProcessor implements MessageGroupProcessor {
+ ForceReleaseMessageGroupProcessor() {
+ super();
+ }
+
@Override
public Object processMessageGroup(MessageGroup group) {
forceComplete(group);
diff --git a/spring-integration-core/src/main/java/org/springframework/integration/aop/PublisherAnnotationAdvisor.java b/spring-integration-core/src/main/java/org/springframework/integration/aop/PublisherAnnotationAdvisor.java
index 5b31225f78..34c72b4f7c 100644
--- a/spring-integration-core/src/main/java/org/springframework/integration/aop/PublisherAnnotationAdvisor.java
+++ b/spring-integration-core/src/main/java/org/springframework/integration/aop/PublisherAnnotationAdvisor.java
@@ -122,7 +122,7 @@ public class PublisherAnnotationAdvisor extends AbstractPointcutAdvisor implemen
* interfaces for the annotation type as well (even if the annotation type
* is not marked as inherited itself)
*/
- private MetaAnnotationMatchingPointcut(Class extends Annotation> classAnnotationType, boolean checkInherited) {
+ MetaAnnotationMatchingPointcut(Class extends Annotation> classAnnotationType, boolean checkInherited) {
this.classFilter = new AnnotationClassFilter(classAnnotationType, checkInherited);
this.methodMatcher = MethodMatcher.TRUE;
}
@@ -134,7 +134,7 @@ public class PublisherAnnotationAdvisor extends AbstractPointcutAdvisor implemen
* @param methodAnnotationType the annotation type to look for at the method level
* (can be null)
*/
- private MetaAnnotationMatchingPointcut(
+ MetaAnnotationMatchingPointcut(
Class extends Annotation> classAnnotationType, Class extends Annotation> methodAnnotationType) {
Assert.isTrue((classAnnotationType != null || methodAnnotationType != null),
@@ -177,7 +177,7 @@ public class PublisherAnnotationAdvisor extends AbstractPointcutAdvisor implemen
* Create a new AnnotationClassFilter for the given annotation type.
* @param annotationType the annotation type to look for
*/
- private MetaAnnotationMethodMatcher(Class extends Annotation> annotationType) {
+ MetaAnnotationMethodMatcher(Class extends Annotation> annotationType) {
super(annotationType);
this.annotationType = annotationType;
}
diff --git a/spring-integration-core/src/main/java/org/springframework/integration/channel/DefaultHeaderChannelRegistry.java b/spring-integration-core/src/main/java/org/springframework/integration/channel/DefaultHeaderChannelRegistry.java
index e60a1b864e..258ac63407 100644
--- a/spring-integration-core/src/main/java/org/springframework/integration/channel/DefaultHeaderChannelRegistry.java
+++ b/spring-integration-core/src/main/java/org/springframework/integration/channel/DefaultHeaderChannelRegistry.java
@@ -235,7 +235,7 @@ public class DefaultHeaderChannelRegistry extends IntegrationObjectSupport
private final long expireAt;
- private MessageChannelWrapper(MessageChannel channel, long expireAt) {
+ MessageChannelWrapper(MessageChannel channel, long expireAt) {
this.channel = channel;
this.expireAt = expireAt;
}
diff --git a/spring-integration-core/src/main/java/org/springframework/integration/channel/ExecutorChannel.java b/spring-integration-core/src/main/java/org/springframework/integration/channel/ExecutorChannel.java
index e780579d33..a58369b1ac 100644
--- a/spring-integration-core/src/main/java/org/springframework/integration/channel/ExecutorChannel.java
+++ b/spring-integration-core/src/main/java/org/springframework/integration/channel/ExecutorChannel.java
@@ -20,13 +20,11 @@ import java.util.concurrent.Executor;
import org.springframework.integration.context.IntegrationProperties;
import org.springframework.integration.dispatcher.LoadBalancingStrategy;
-import org.springframework.integration.dispatcher.MessageHandlingTaskDecorator;
import org.springframework.integration.dispatcher.RoundRobinLoadBalancingStrategy;
import org.springframework.integration.dispatcher.UnicastingDispatcher;
import org.springframework.integration.support.channel.BeanFactoryChannelResolver;
import org.springframework.integration.util.ErrorHandlingTaskExecutor;
import org.springframework.messaging.MessageChannel;
-import org.springframework.messaging.support.MessageHandlingRunnable;
import org.springframework.util.Assert;
import org.springframework.util.ErrorHandler;
@@ -120,18 +118,13 @@ public class ExecutorChannel extends AbstractExecutorChannel {
unicastingDispatcher.setLoadBalancingStrategy(this.loadBalancingStrategy);
}
- unicastingDispatcher.setMessageHandlingTaskDecorator(new MessageHandlingTaskDecorator() {
-
- @Override
- public Runnable decorate(MessageHandlingRunnable task) {
- if (ExecutorChannel.this.executorInterceptorsSize > 0) {
- return new MessageHandlingTask(task);
- }
- else {
- return task;
- }
+ unicastingDispatcher.setMessageHandlingTaskDecorator(task -> {
+ if (ExecutorChannel.this.executorInterceptorsSize > 0) {
+ return new MessageHandlingTask(task);
+ }
+ else {
+ return task;
}
-
});
this.dispatcher = unicastingDispatcher;
diff --git a/spring-integration-core/src/main/java/org/springframework/integration/channel/PriorityChannel.java b/spring-integration-core/src/main/java/org/springframework/integration/channel/PriorityChannel.java
index 60dd1f00fb..c61775cbfd 100644
--- a/spring-integration-core/src/main/java/org/springframework/integration/channel/PriorityChannel.java
+++ b/spring-integration-core/src/main/java/org/springframework/integration/channel/PriorityChannel.java
@@ -112,7 +112,7 @@ public class PriorityChannel extends QueueChannel {
private final Comparator> targetComparator;
- private SequenceFallbackComparator(Comparator> targetComparator) {
+ SequenceFallbackComparator(Comparator> targetComparator) {
this.targetComparator = targetComparator;
}
@@ -145,7 +145,7 @@ public class PriorityChannel extends QueueChannel {
private final Message> rootMessage;
private final long sequence;
- private MessageWrapper(Message> rootMessage) {
+ MessageWrapper(Message> rootMessage) {
this.rootMessage = rootMessage;
this.sequence = PriorityChannel.this.sequenceCounter.incrementAndGet();
}
diff --git a/spring-integration-core/src/main/java/org/springframework/integration/channel/PublishSubscribeChannel.java b/spring-integration-core/src/main/java/org/springframework/integration/channel/PublishSubscribeChannel.java
index f377e920c7..3e732ee84a 100644
--- a/spring-integration-core/src/main/java/org/springframework/integration/channel/PublishSubscribeChannel.java
+++ b/spring-integration-core/src/main/java/org/springframework/integration/channel/PublishSubscribeChannel.java
@@ -20,10 +20,8 @@ import java.util.concurrent.Executor;
import org.springframework.integration.context.IntegrationProperties;
import org.springframework.integration.dispatcher.BroadcastingDispatcher;
-import org.springframework.integration.dispatcher.MessageHandlingTaskDecorator;
import org.springframework.integration.support.channel.BeanFactoryChannelResolver;
import org.springframework.integration.util.ErrorHandlingTaskExecutor;
-import org.springframework.messaging.support.MessageHandlingRunnable;
import org.springframework.util.Assert;
import org.springframework.util.ErrorHandler;
@@ -158,18 +156,13 @@ public class PublishSubscribeChannel extends AbstractExecutorChannel {
}
getDispatcher().setBeanFactory(this.getBeanFactory());
- getDispatcher().setMessageHandlingTaskDecorator(new MessageHandlingTaskDecorator() {
-
- @Override
- public Runnable decorate(MessageHandlingRunnable task) {
- if (PublishSubscribeChannel.this.executorInterceptorsSize > 0) {
- return new MessageHandlingTask(task);
- }
- else {
- return task;
- }
+ getDispatcher().setMessageHandlingTaskDecorator(task -> {
+ if (PublishSubscribeChannel.this.executorInterceptorsSize > 0) {
+ return new MessageHandlingTask(task);
+ }
+ else {
+ return task;
}
-
});
}
diff --git a/spring-integration-core/src/main/java/org/springframework/integration/channel/interceptor/ThreadStatePropagationChannelInterceptor.java b/spring-integration-core/src/main/java/org/springframework/integration/channel/interceptor/ThreadStatePropagationChannelInterceptor.java
index 5e7212b6c7..5b8fd27f46 100644
--- a/spring-integration-core/src/main/java/org/springframework/integration/channel/interceptor/ThreadStatePropagationChannelInterceptor.java
+++ b/spring-integration-core/src/main/java/org/springframework/integration/channel/interceptor/ThreadStatePropagationChannelInterceptor.java
@@ -99,7 +99,7 @@ public abstract class ThreadStatePropagationChannelInterceptor
private final S state;
@SuppressWarnings("unchecked")
- private MessageWithThreadState(Message> message, S state) {
+ MessageWithThreadState(Message> message, S state) {
this.message = (Message