diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/ConsumerProperties.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/ConsumerProperties.java index 3eaae8be1..f11e5331d 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/ConsumerProperties.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/ConsumerProperties.java @@ -16,11 +16,16 @@ package org.springframework.cloud.stream.binder; +import static com.fasterxml.jackson.annotation.JsonInclude.Include.NON_DEFAULT; + +import com.fasterxml.jackson.annotation.JsonInclude; + /** * Common consumer properties. * * @author Marius Bogoevici */ +@JsonInclude(NON_DEFAULT) public class ConsumerProperties { private int concurrency = 1; diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/ProducerProperties.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/ProducerProperties.java index dc5183861..a9f2ef79e 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/ProducerProperties.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/ProducerProperties.java @@ -16,15 +16,20 @@ package org.springframework.cloud.stream.binder; -import org.springframework.expression.Expression; +import com.fasterxml.jackson.annotation.JsonInclude; +import com.fasterxml.jackson.annotation.JsonInclude.Include; import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import org.springframework.expression.Expression; + /** * Common producer properties. * * @author Marius Bogoevici + * @author Ilayaperumal Gopinathan */ +@JsonInclude(Include.NON_DEFAULT) public class ProducerProperties { @JsonSerialize(using = ExpressionSerializer.class) diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/DynamicDestinationsBindable.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/DynamicDestinationsBindable.java index fbbbf3ce6..63a8a0ec7 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/DynamicDestinationsBindable.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/DynamicDestinationsBindable.java @@ -32,7 +32,7 @@ import org.springframework.cloud.stream.binder.Binding; public final class DynamicDestinationsBindable extends BindableAdapter { /** - * Map containing channel names and their bindings. + * Map containing dynamic channel names and their bindings. */ private Map outputBindings = new HashMap<>();