INT-4298: Add Interface HeaderPropagationAware

JIRA: https://jira.spring.io/browse/INT-4298

Used to indicate components that can propagate headers; allows suppression.

Move Interface to AbstractMessageProducingHandler

Add Docs

* Fix typo in doc

(cherry picked from commit 42dd05d)

spring-integration-core/src/main/java/org/springframework/integration/handler/AbstractMessageProducingHandler.java

@@ -55,7 +55,7 @@ import org.springframework.util.concurrent.ListenableFutureCallback;
  * since 4.1
  */
 public abstract class AbstractMessageProducingHandler extends AbstractMessageHandler
-		implements MessageProducer {
+		implements MessageProducer, HeaderPropagationAware {
 
 	private final Set<String> notPropagatedHeaders = new HashSet<String>();
 
@@ -113,6 +113,7 @@ public abstract class AbstractMessageProducingHandler extends AbstractMessageHan
 	 * @param headers the headers to not propagate from the inbound message.
 	 * @since 4.3.10
 	 */
+	@Override
 	public void setNotPropagatedHeaders(String... headers) {
 		updateNotPropagatedHeaders(headers, false);
 	}
@@ -130,24 +131,25 @@ public abstract class AbstractMessageProducingHandler extends AbstractMessageHan
 
 	/**
 	 * Get the header names this handler doesn't propagate.
-	 * @return an immutable {@link java.util.Collection} of headers that will
-	 *         not be copied from the inbound message if
-	 *         {@link #shouldCopyRequestHeaders()} is true.
+	 * @return an immutable {@link java.util.Collection} of headers that will not be
+	 * copied from the inbound message if {@link #shouldCopyRequestHeaders()} is true.
 	 * @since 4.3.10
 	 * @see #setNotPropagatedHeaders(String...)
 	 */
+	@Override
 	public Collection<String> getNotPropagatedHeaders() {
 		return Collections.unmodifiableSet(this.notPropagatedHeaders);
 	}
 
 	/**
 	 * Add headers that will NOT be copied from the inbound message if
-	 * {@link #shouldCopyRequestHeaders()} is true, instead of overwriting
-	 * the existing set.
+	 * {@link #shouldCopyRequestHeaders()} is true, instead of overwriting the existing
+	 * set.
 	 * @param headers the headers to not propagate from the inbound message.
 	 * @since 4.3.10
 	 * @see #setNotPropagatedHeaders(String...)
 	 */
+	@Override
 	public void addNotPropagatedHeaders(String... headers) {
 		updateNotPropagatedHeaders(headers, true);
 	}

spring-integration-core/src/main/java/org/springframework/integration/handler/HeaderPropagationAware.java

@@ -0,0 +1,55 @@
+/*
+ * Copyright 2017 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.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.handler;
+
+import java.util.Collection;
+
+/**
+ * MessageHandlers implementing this interface can propagate headers from
+ * an input message to an output message.
+ *
+ * @author Gary Russell
+ * @since 4.3.11
+ *
+ */
+public interface HeaderPropagationAware {
+
+	/**
+	 * Set headers that will NOT be copied from the inbound message if
+	 * the handler is configured to copy headers.
+	 * @param headers the headers to not propagate from the inbound message.
+	 */
+	void setNotPropagatedHeaders(String... headers);
+
+	/**
+	 * Get the header names this handler doesn't propagate.
+	 * @return an immutable {@link java.util.Collection} of headers that will not be
+	 * copied from the inbound message if the handler is configured to copy headers.
+	 * @see #setNotPropagatedHeaders(String...)
+	 */
+	Collection<String> getNotPropagatedHeaders();
+
+	/**
+	 * Add headers that will NOT be copied from the inbound message if
+	 * the handler is configured to copy headers, instead of overwriting
+	 * the existing set.
+	 * @param headers the headers to not propagate from the inbound message.
+	 * @see #setNotPropagatedHeaders(String...)
+	 */
+	void addNotPropagatedHeaders(String... headers);
+
+}