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 5df27ccf5..85f947bca 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 @@ -86,24 +86,19 @@ import org.springframework.util.Assert; * * @since 1.1 */ -// @checkstyle:off public abstract class AbstractMessageChannelBinder> extends AbstractBinder implements PollableConsumerBinder, ApplicationEventPublisherAware { - // @checkstyle:on /** * {@link ProvisioningProvider} delegated by the downstream binder implementations. */ protected final PP provisioningProvider; - // @checkstyle:off private final EmbeddedHeadersChannelInterceptor embeddedHeadersChannelInterceptor = new EmbeddedHeadersChannelInterceptor( this.logger); - // @checkstyle:on - private final ObjectMapper objectMapper = new ObjectMapper(); /** @@ -121,14 +116,6 @@ public abstract class AbstractMessageChannelBinder Stream.of(binderType.getConfigurationClasses()) - .anyMatch(clazz -> AnnotationUtils.findAnnotation(clazz, BindingProvider.class) == null)); - } - private boolean determineFunctionName(FunctionCatalog catalog, Environment environment) { String definition = streamFunctionProperties.getDefinition(); if (!StringUtils.hasText(definition)) {