Minor Polishing

Unused imports etc.

Author: garyrussell

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

@@ -70,7 +70,7 @@ private static <T> Publisher<Message<T>> adaptPollableChannelToPublisher(Pollabl
 	}
 
 
-	private final static class SubscribableChannelPublisherAdapter<T> implements Publisher<Message<T>> {
+	private static final class SubscribableChannelPublisherAdapter<T> implements Publisher<Message<T>> {
 
 		private final SubscribableChannel channel;
 
@@ -93,7 +93,7 @@ public void subscribe(Subscriber<? super Message<T>> subscriber) {
 
 	}
 
-	private final static class PollableChannelPublisherAdapter<T> implements Publisher<Message<T>> {
+	private static final class PollableChannelPublisherAdapter<T> implements Publisher<Message<T>> {
 
 		private final PollableChannel channel;
 

spring-integration-core/src/main/java/org/springframework/integration/dsl/IntegrationFlowDefinition.java

@@ -34,7 +34,6 @@
 import org.springframework.expression.spel.standard.SpelExpressionParser;
 import org.springframework.integration.aggregator.AggregatingMessageHandler;
 import org.springframework.integration.aggregator.BarrierMessageHandler;
-import org.springframework.integration.aggregator.ResequencingMessageHandler;
 import org.springframework.integration.channel.ChannelInterceptorAware;
 import org.springframework.integration.channel.DirectChannel;
 import org.springframework.integration.channel.FixedSubscriberChannel;
@@ -54,7 +53,6 @@
 import org.springframework.integration.filter.ExpressionEvaluatingSelector;
 import org.springframework.integration.filter.MessageFilter;
 import org.springframework.integration.filter.MethodInvokingSelector;
-import org.springframework.integration.gateway.GatewayMessageHandler;
 import org.springframework.integration.handler.AbstractMessageProducingHandler;
 import org.springframework.integration.handler.BeanNameMessageProcessor;
 import org.springframework.integration.handler.BridgeHandler;
@@ -1725,15 +1723,19 @@ public B claimCheckOut(MessageStore messageStore, boolean removeMessage,
 	}
 
 	/**
-	 * Populate the {@link ResequencingMessageHandler} with default options.
+	 * Populate the
+	 * {@link org.springframework.integration.aggregator.ResequencingMessageHandler} with
+	 * default options.
 	 * @return the current {@link IntegrationFlowDefinition}.
 	 */
 	public B resequence() {
 		return resequence(null);
 	}
 
 	/**
-	 * Populate the {@link ResequencingMessageHandler} with provided options from {@link ResequencerSpec}.
+	 * Populate the
+	 * {@link org.springframework.integration.aggregator.ResequencingMessageHandler} with
+	 * provided options from {@link ResequencerSpec}.
 	 * In addition accept options for the integration endpoint using {@link GenericEndpointSpec}.
 	 * Typically used with a Java 8 Lambda expression:
 	 * <pre class="code">
@@ -1743,7 +1745,8 @@ public B resequence() {
 	 *                    .phase(100))
 	 * }
 	 * </pre>
-	 * @param resequencer the {@link Consumer} to provide {@link ResequencingMessageHandler} options.
+	 * @param resequencer the {@link Consumer} to provide
+	 * {@link org.springframework.integration.aggregator.ResequencingMessageHandler} options.
 	 * @return the current {@link IntegrationFlowDefinition}.
 	 * @see ResequencerSpec
 	 */
@@ -2254,8 +2257,9 @@ public <R extends AbstractMessageRouter> B route(R router, Consumer<GenericEndpo
 	}
 
 	/**
-	 * Populate the "artificial" {@link GatewayMessageHandler} for the provided
-	 * {@code requestChannel} to send a request with default options.
+	 * Populate the "artificial"
+	 * {@link org.springframework.integration.gateway.GatewayMessageHandler} for the
+	 * provided {@code requestChannel} to send a request with default options.
 	 * Uses {@link org.springframework.integration.gateway.RequestReplyExchanger} Proxy
 	 * on the background.
 	 * @param requestChannel the {@link MessageChannel} bean name.
@@ -2266,23 +2270,27 @@ public B gateway(String requestChannel) {
 	}
 
 	/**
-	 * Populate the "artificial" {@link GatewayMessageHandler} for the provided
-	 * {@code requestChannel} to send a request with options from {@link GatewayEndpointSpec}.
-	 * Uses {@link org.springframework.integration.gateway.RequestReplyExchanger} Proxy
-	 * on the background.
+	 * Populate the "artificial"
+	 * {@link org.springframework.integration.gateway.GatewayMessageHandler} for the
+	 * provided {@code requestChannel} to send a request with options from
+	 * {@link GatewayEndpointSpec}. Uses
+	 * {@link org.springframework.integration.gateway.RequestReplyExchanger} Proxy on the
+	 * background.
 	 * @param requestChannel the {@link MessageChannel} bean name.
-	 * @param endpointConfigurer the {@link Consumer} to provide integration endpoint options.
+	 * @param endpointConfigurer the {@link Consumer} to provide integration endpoint
+	 * options.
 	 * @return the current {@link IntegrationFlowDefinition}.
 	 */
 	public B gateway(String requestChannel, Consumer<GatewayEndpointSpec> endpointConfigurer) {
 		return register(new GatewayEndpointSpec(requestChannel), endpointConfigurer);
 	}
 
 	/**
-	 * Populate the "artificial" {@link GatewayMessageHandler} for the provided
-	 * {@code requestChannel} to send a request with default options.
-	 * Uses {@link org.springframework.integration.gateway.RequestReplyExchanger} Proxy
-	 * on the background.
+	 * Populate the "artificial"
+	 * {@link org.springframework.integration.gateway.GatewayMessageHandlerGatewayMessageHandler}
+	 * for the provided {@code requestChannel} to send a request with default options.
+	 * Uses {@link org.springframework.integration.gateway.RequestReplyExchanger} Proxy on
+	 * the background.
 	 * @param requestChannel the {@link MessageChannel} to use.
 	 * @return the current {@link IntegrationFlowDefinition}.
 	 */
@@ -2291,21 +2299,25 @@ public B gateway(MessageChannel requestChannel) {
 	}
 
 	/**
-	 * Populate the "artificial" {@link GatewayMessageHandler} for the provided
-	 * {@code requestChannel} to send a request with options from {@link GatewayEndpointSpec}.
-	 * Uses {@link org.springframework.integration.gateway.RequestReplyExchanger} Proxy
-	 * on the background.
+	 * Populate the "artificial"
+	 * {@link org.springframework.integration.gateway.GatewayMessageHandler} for the
+	 * provided {@code requestChannel} to send a request with options from
+	 * {@link GatewayEndpointSpec}. Uses
+	 * {@link org.springframework.integration.gateway.RequestReplyExchanger} Proxy on the
+	 * background.
 	 * @param requestChannel the {@link MessageChannel} to use.
-	 * @param endpointConfigurer the {@link Consumer} to provide integration endpoint options.
+	 * @param endpointConfigurer the {@link Consumer} to provide integration endpoint
+	 * options.
 	 * @return the current {@link IntegrationFlowDefinition}.
 	 */
 	public B gateway(MessageChannel requestChannel, Consumer<GatewayEndpointSpec> endpointConfigurer) {
 		return register(new GatewayEndpointSpec(requestChannel), endpointConfigurer);
 	}
 
 	/**
-	 * Populate the "artificial" {@link GatewayMessageHandler} for the provided
-	 * {@code subflow}.
+	 * Populate the "artificial"
+	 * {@link org.springframework.integration.gateway.GatewayMessageHandler} for the
+	 * provided {@code subflow}.
 	 * Typically used with a Java 8 Lambda expression:
 	 * <pre class="code">
 	 * {@code
@@ -2320,8 +2332,9 @@ public B gateway(IntegrationFlow flow) {
 	}
 
 	/**
-	 * Populate the "artificial" {@link GatewayMessageHandler} for the provided
-	 * {@code subflow} with options from {@link GatewayEndpointSpec}.
+	 * Populate the "artificial"
+	 * {@link org.springframework.integration.gateway.GatewayMessageHandler} for the
+	 * provided {@code subflow} with options from {@link GatewayEndpointSpec}.
 	 * Typically used with a Java 8 Lambda expression:
 	 * <pre class="code">
 	 * {@code

spring-integration-core/src/main/java/org/springframework/integration/dsl/IntegrationFlows.java

@@ -20,7 +20,6 @@
 
 import org.reactivestreams.Publisher;
 
-import org.springframework.integration.annotation.MessagingGateway;
 import org.springframework.integration.channel.DirectChannel;
 import org.springframework.integration.channel.ReactiveChannel;
 import org.springframework.integration.core.MessageSource;
@@ -269,12 +268,13 @@ public static IntegrationFlowBuilder from(MessagingGatewaySupport inboundGateway
 	}
 
 	/**
-	 * Populate the {@link MessageChannel} to the new {@link IntegrationFlowBuilder} chain,
-	 * which becomes as a {@code requestChannel} for the Messaging Gateway(s) built on the provided
-	 * service interface.
-	 * <p> A gateway proxy bean for provided service interface is registered
-	 * under a name of the {@link IntegrationFlow} bean plus {@code .gateway} suffix.
-	 * @param serviceInterface the class with a {@link MessagingGateway} annotation.
+	 * Populate the {@link MessageChannel} to the new {@link IntegrationFlowBuilder}
+	 * chain, which becomes as a {@code requestChannel} for the Messaging Gateway(s) built
+	 * on the provided service interface.
+	 * <p>A gateway proxy bean for provided service interface is registered under a name of
+	 * the {@link IntegrationFlow} bean plus {@code .gateway} suffix.
+	 * @param serviceInterface the class with a
+	 * {@link org.springframework.integration.annotation.MessagingGateway} annotation.
 	 * @return new {@link IntegrationFlowBuilder}.
 	 */
 	public static IntegrationFlowBuilder from(Class<?> serviceInterface) {