checkstyle FinalClassCheck

fixes

fixModifiers after fixFinal

Revert CachingSessionFactory

Class is spied in tests.

checkstyle - Import Rules

checkstyle InterfaceIsType

checkstyle InnerTypeLast

checkstyle OneStatementPerLine

CovariantEquals
OneTopLevelClass

* Revert `'\n'` -> `System.lineSeparator()` in the Gradle scripts to meet Git `autocrlf = true` on Windows
* Fix timing issue with the `LastModifiedFileListFilterTests`, when the `age = 1` might not be enough for the file object when we have some delay before checking

Author: garyrussell

build.gradle

@@ -64,6 +64,7 @@ subprojects { subproject ->
 	apply plugin: 'jacoco'
 	apply plugin: 'checkstyle'
 
+	apply from:   "${rootDir}/src/checkstyle/fixFinal.gradle"
 	apply from:   "${rootDir}/src/checkstyle/fixHeaders.gradle"
 	apply from:   "${rootDir}/src/checkstyle/fixModifiers.gradle"
 	apply from:   "${rootDir}/src/checkstyle/fixThis.gradle"

spring-integration-amqp/src/main/java/org/springframework/integration/amqp/channel/AbstractSubscribableAmqpChannel.java

@@ -201,12 +201,59 @@ public void onInit() throws Exception {
 		}
 	}
 
+	/*
+	 * SmartLifecycle implementation (delegates to the MessageListener container)
+	 */
+
+	@Override
+	public boolean isAutoStartup() {
+		return (this.container != null) && this.container.isAutoStartup();
+	}
+
+	@Override
+	public int getPhase() {
+		return (this.container != null) ? this.container.getPhase() : 0;
+	}
+
+	@Override
+	public boolean isRunning() {
+		return (this.container != null) && this.container.isRunning();
+	}
+
+	@Override
+	public void start() {
+		if (this.container != null) {
+			this.container.start();
+		}
+	}
+
+	@Override
+	public void stop() {
+		if (this.container != null) {
+			this.container.stop();
+		}
+	}
+
+	@Override
+	public void stop(Runnable callback) {
+		if (this.container != null) {
+			this.container.stop(callback);
+		}
+	}
+
+	@Override
+	public void destroy() throws Exception {
+		if (this.container != null) {
+			this.container.destroy();
+		}
+	}
+
 	protected abstract AbstractDispatcher createDispatcher();
 
 	protected abstract String obtainQueueName(AmqpAdmin admin, String channelName);
 
 
-	private static class DispatchingMessageListener implements MessageListener {
+	private static final class DispatchingMessageListener implements MessageListener {
 
 		private final Log logger = LogFactory.getLog(this.getClass());
 
@@ -283,52 +330,4 @@ protected Message<Object> buildMessage(org.springframework.amqp.core.Message mes
 
 	}
 
-
-	/*
-	 * SmartLifecycle implementation (delegates to the MessageListener container)
-	 */
-
-	@Override
-	public boolean isAutoStartup() {
-		return (this.container != null) && this.container.isAutoStartup();
-	}
-
-	@Override
-	public int getPhase() {
-		return (this.container != null) ? this.container.getPhase() : 0;
-	}
-
-	@Override
-	public boolean isRunning() {
-		return (this.container != null) && this.container.isRunning();
-	}
-
-	@Override
-	public void start() {
-		if (this.container != null) {
-			this.container.start();
-		}
-	}
-
-	@Override
-	public void stop() {
-		if (this.container != null) {
-			this.container.stop();
-		}
-	}
-
-	@Override
-	public void stop(Runnable callback) {
-		if (this.container != null) {
-			this.container.stop(callback);
-		}
-	}
-
-	@Override
-	public void destroy() throws Exception {
-		if (this.container != null) {
-			this.container.destroy();
-		}
-	}
-
 }

spring-integration-amqp/src/main/java/org/springframework/integration/amqp/outbound/AbstractAmqpOutboundEndpoint.java

@@ -431,7 +431,7 @@ else if (!ack && this.confirmNackChannel != null) {
 		}
 	}
 
-	protected static class CorrelationDataWrapper extends CorrelationData {
+	protected static final class CorrelationDataWrapper extends CorrelationData {
 
 		private final Object userData;
 

spring-integration-amqp/src/main/java/org/springframework/integration/amqp/support/MappingUtils.java

@@ -30,7 +30,7 @@
  * @since 4.3
  *
  */
-public class MappingUtils {
+public final class MappingUtils {
 
 	private MappingUtils() {
 		super();

spring-integration-core/src/main/java/org/springframework/integration/annotation/GatewayHeader.java

@@ -16,9 +16,8 @@
 
 package org.springframework.integration.annotation;
 
-import static java.lang.annotation.RetentionPolicy.RUNTIME;
-
 import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
 import java.lang.annotation.Target;
 
 /**
@@ -28,7 +27,7 @@
  * @since 4.0
  */
 @Target({ })
-@Retention(RUNTIME)
+@Retention(RetentionPolicy.RUNTIME)
 public @interface GatewayHeader {
 
 	/**

spring-integration-core/src/main/java/org/springframework/integration/annotation/Poller.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2014-2015 the original author or authors.
+ * Copyright 2014-2016 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.
@@ -16,9 +16,8 @@
 
 package org.springframework.integration.annotation;
 
-import static java.lang.annotation.RetentionPolicy.RUNTIME;
-
 import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
 import java.lang.annotation.Target;
 
 import org.springframework.integration.scheduling.PollerMetadata;
@@ -43,7 +42,7 @@
  * @since 4.0
  */
 @Target({})
-@Retention(RUNTIME)
+@Retention(RetentionPolicy.RUNTIME)
 public @interface Poller {
 
 	/**

spring-integration-core/src/main/java/org/springframework/integration/aop/PublisherAnnotationAdvisor.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2014 the original author or authors.
+ * Copyright 2002-2016 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.
@@ -108,7 +108,7 @@ private Pointcut buildPointcut() {
 	}
 
 
-	private static class MetaAnnotationMatchingPointcut implements Pointcut {
+	private static final class MetaAnnotationMatchingPointcut implements Pointcut {
 
 		private final ClassFilter classFilter;
 
@@ -168,7 +168,7 @@ public MethodMatcher getMethodMatcher() {
 	}
 
 
-	private static class MetaAnnotationMethodMatcher extends AnnotationMethodMatcher {
+	private static final class MetaAnnotationMethodMatcher extends AnnotationMethodMatcher {
 
 		private final Class<? extends Annotation> annotationType;
 

spring-integration-core/src/main/java/org/springframework/integration/channel/DefaultHeaderChannelRegistry.java

@@ -226,7 +226,7 @@ public synchronized void run() {
 	}
 
 
-	private class MessageChannelWrapper {
+	private final class MessageChannelWrapper {
 
 		private final MessageChannel channel;
 
@@ -237,11 +237,11 @@ private MessageChannelWrapper(MessageChannel channel, long expireAt) {
 			this.expireAt = expireAt;
 		}
 
-		public final long getExpireAt() {
+		public long getExpireAt() {
 			return this.expireAt;
 		}
 
-		public final MessageChannel getChannel() {
+		public MessageChannel getChannel() {
 			return this.channel;
 		}
 

spring-integration-core/src/main/java/org/springframework/integration/channel/PriorityChannel.java

@@ -103,7 +103,7 @@ protected Message<?> doReceive(long timeout) {
 		return message;
 	}
 
-	private static class SequenceFallbackComparator implements Comparator<Message<?>> {
+	private static final class SequenceFallbackComparator implements Comparator<Message<?>> {
 
 		private final Comparator<Message<?>> targetComparator;
 
@@ -136,7 +136,7 @@ public int compare(Message<?> message1, Message<?> message2) {
 	}
 
 	//we need this because of INT-2508
-	private class MessageWrapper implements Message<Object> {
+	private final class MessageWrapper implements Message<Object> {
 		private final Message<?> rootMessage;
 		private final long sequence;
 

spring-integration-core/src/main/java/org/springframework/integration/channel/interceptor/ThreadStatePropagationChannelInterceptor.java

@@ -91,7 +91,7 @@ public void afterMessageHandled(Message<?> message, MessageChannel channel, Mess
 	protected abstract void populatePropagatedContext(S state, Message<?> message, MessageChannel channel);
 
 
-	private static class MessageWithThreadState<S> implements Message<Object> {
+	private static final class MessageWithThreadState<S> implements Message<Object> {
 
 		private final Message<?> message;