diff --git a/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/IntegrationRSocketAcceptor.java b/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/IntegrationRSocketAcceptor.java index e11e0ae66b..44c9019019 100644 --- a/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/IntegrationRSocketAcceptor.java +++ b/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/IntegrationRSocketAcceptor.java @@ -136,7 +136,7 @@ class IntegrationRSocketAcceptor extends RSocketMessageHandler Assert.notNull(dataMimeType, "No `dataMimeType` in the ConnectionSetupPayload and no default value"); MimeType metadataMimeType = - StringUtils.hasText(setupPayload.dataMimeType()) + StringUtils.hasText(setupPayload.metadataMimeType()) ? MimeTypeUtils.parseMimeType(setupPayload.metadataMimeType()) : this.defaultMetadataMimeType; Assert.notNull(dataMimeType, "No `metadataMimeType` in the ConnectionSetupPayload and no default value"); diff --git a/spring-integration-rsocket/src/test/java/org/springframework/integration/rsocket/config/RSocketInboundGatewayParserTests-context.xml b/spring-integration-rsocket/src/test/java/org/springframework/integration/rsocket/config/RSocketInboundGatewayParserTests-context.xml index d8f13b7c7d..d1c5fed8be 100644 --- a/spring-integration-rsocket/src/test/java/org/springframework/integration/rsocket/config/RSocketInboundGatewayParserTests-context.xml +++ b/spring-integration-rsocket/src/test/java/org/springframework/integration/rsocket/config/RSocketInboundGatewayParserTests-context.xml @@ -9,6 +9,7 @@ + diff --git a/spring-integration-rsocket/src/test/java/org/springframework/integration/rsocket/config/RSocketOutboundGatewayParserTests-context.xml b/spring-integration-rsocket/src/test/java/org/springframework/integration/rsocket/config/RSocketOutboundGatewayParserTests-context.xml index 61606b4be4..32ccf1561c 100644 --- a/spring-integration-rsocket/src/test/java/org/springframework/integration/rsocket/config/RSocketOutboundGatewayParserTests-context.xml +++ b/spring-integration-rsocket/src/test/java/org/springframework/integration/rsocket/config/RSocketOutboundGatewayParserTests-context.xml @@ -9,6 +9,7 @@ +