diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/AbstractMessageChannelBinder.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/AbstractMessageChannelBinder.java index 977c47e05..067f44b2f 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/AbstractMessageChannelBinder.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/AbstractMessageChannelBinder.java @@ -53,7 +53,7 @@ import org.springframework.util.MimeType; * @author Soby Chacko * @since 1.1 */ -public abstract class AbstractMessageChannelBinder +public abstract class AbstractMessageChannelBinder> extends AbstractBinder { protected static final ExpressionParser EXPRESSION_PARSER = new SpelExpressionParser(); @@ -74,10 +74,13 @@ public abstract class AbstractMessageChannelBinder provisioningProvider; + /** + * {@link ProvisioningProvider} delegated by the downstream binder implementations. + */ + protected final PP provisioningProvider; public AbstractMessageChannelBinder(boolean supportsHeadersNatively, String[] headersToEmbed, - ProvisioningProvider provisioningProvider) { + PP provisioningProvider) { this.supportsHeadersNatively = supportsHeadersNatively; this.headersToEmbed = headersToEmbed; this.provisioningProvider = provisioningProvider;