SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix boolean getter methods

Browse Source 
- on BindingProperties
This commit is contained in:
Ilayaperumal Gopinathan
2016-01-28 23:05:15 +05:30
parent 40709fbf14
commit 73abe565fd
3 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/MessageHistoryTrackerConfigurer.java
View File

@@ -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() {

8
spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BindingProperties.java
View File

@@ -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;
}

10
spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/ChannelBindingServiceProperties.java
View File

@@ -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,