diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/MessageHistoryTrackerConfigurer.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/MessageHistoryTrackerConfigurer.java index 50efbd070..bb7badf64 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/MessageHistoryTrackerConfigurer.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/MessageHistoryTrackerConfigurer.java @@ -50,7 +50,7 @@ public class MessageHistoryTrackerConfigurer implements MessageChannelConfigurer @Override public void configureMessageChannel(MessageChannel messageChannel, String channelName) { BindingProperties bindingProperties = channelBindingServiceProperties.getBindings().get(channelName); - if (bindingProperties != null && Boolean.TRUE.equals(bindingProperties.getTrackHistory())) { + if (bindingProperties != null && Boolean.TRUE.equals(bindingProperties.isTrackHistory())) { if (messageChannel instanceof ChannelInterceptorAware) { ((ChannelInterceptorAware) messageChannel).addInterceptor(new ChannelInterceptorAdapter() { diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BindingProperties.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BindingProperties.java index a70cee0e8..4efb203ee 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BindingProperties.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BindingProperties.java @@ -125,7 +125,7 @@ public class BindingProperties { this.binder = binder; } - public Boolean getTrackHistory() { + public Boolean isTrackHistory() { return this.trackHistory; } @@ -181,7 +181,7 @@ public class BindingProperties { this.nextModuleConcurrency = nextModuleConcurrency; } - public Boolean getBatchingEnabled() { + public Boolean isBatchingEnabled() { return this.batchingEnabled; } @@ -237,7 +237,7 @@ public class BindingProperties { this.partitionIndex = partitionIndex; } - public Boolean getPartitioned() { + public Boolean isPartitioned() { return this.partitioned; } @@ -245,7 +245,7 @@ public class BindingProperties { this.partitioned = partitioned; } - public Boolean getDurableSubscription() { + public Boolean isDurableSubscription() { return this.durableSubscription; } diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/ChannelBindingServiceProperties.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/ChannelBindingServiceProperties.java index a879de3a7..f529dfd32 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/ChannelBindingServiceProperties.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/ChannelBindingServiceProperties.java @@ -112,9 +112,9 @@ public class ChannelBindingServiceProperties { channelConsumerProperties.setProperty(BinderPropertyKeys.CONCURRENCY, Integer.toString(bindingProperties.getConcurrency())); } - if (bindingProperties.getDurableSubscription() != null) { + if (bindingProperties.isDurableSubscription() != null) { channelConsumerProperties.setProperty(BinderPropertyKeys.DURABLE, - Boolean.toString(bindingProperties.getDurableSubscription())); + Boolean.toString(bindingProperties.isDurableSubscription())); } updateConsumerPartitionProperties(inputChannelName, channelConsumerProperties); } @@ -136,7 +136,7 @@ public class ChannelBindingServiceProperties { private boolean isPartitionedConsumer(String channelName) { BindingProperties bindingProperties = bindings.get(channelName); - return bindingProperties != null && bindingProperties.getPartitioned(); + return bindingProperties != null && bindingProperties.isPartitioned(); } private boolean isPartitionedProducer(String channelName) { @@ -148,9 +148,9 @@ public class ChannelBindingServiceProperties { private void updateBatchProperties(String outputChannelName, Properties producerProperties) { BindingProperties bindingProperties = this.bindings.get(outputChannelName); if (bindingProperties != null) { - if (bindingProperties.getBatchingEnabled() != null) { + if (bindingProperties.isBatchingEnabled() != null) { producerProperties.setProperty(BinderPropertyKeys.BATCHING_ENABLED, - String.valueOf(bindingProperties.getBatchingEnabled())); + String.valueOf(bindingProperties.isBatchingEnabled())); } if (bindingProperties.getBatchSize() != null) { producerProperties.setProperty(BinderPropertyKeys.BATCH_SIZE,