diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/EnvironmentEntryInitializingTreeMap.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/EnvironmentEntryInitializingTreeMap.java index c9d2ea68b..32bb66cd5 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/EnvironmentEntryInitializingTreeMap.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/EnvironmentEntryInitializingTreeMap.java @@ -113,7 +113,8 @@ public class EnvironmentEntryInitializingTreeMap extends AbstractMap bindings = bindingServiceProperties.getBindings(); @@ -461,6 +463,10 @@ public class BindingServiceTests { assertThat(bindings.get("input2").getConsumer().isPartitioned()).isEqualTo(false); assertThat(bindings.get("output1").getProducer().getPartitionCount()).isEqualTo(10); assertThat(bindings.get("output2").getProducer().getPartitionCount()).isEqualTo(1); + + assertThat(bindings.get("inputXyz").getContentType()).isEqualTo("application/json"); + assertThat(bindings.get("inputFooBar").getContentType()).isEqualTo("application/avro"); + assertThat(bindings.get("inputFooBarBuzz").getContentType()).isEqualTo("text/plain"); } @EnableBinding(FooBinding.class) @@ -485,6 +491,15 @@ public class BindingServiceTests { @Output("output2") MessageChannel out2(); + + @Input("inputXyz") + SubscribableChannel inXyz(); + + @Input("inputFooBar") + SubscribableChannel inFooBar(); + + @Input("inputFooBarBuzz") + SubscribableChannel inFooBarBuzz(); } @Test