Skip to content

Commit 36c14ef

Browse files
committed
Some polishing for RSocket support
1 parent 244e594 commit 36c14ef

File tree

3 files changed

+3
-1
lines changed

3 files changed

+3
-1
lines changed

spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/IntegrationRSocketAcceptor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -136,7 +136,7 @@ protected IntegrationRSocket createRSocket(ConnectionSetupPayload setupPayload,
136136
Assert.notNull(dataMimeType, "No `dataMimeType` in the ConnectionSetupPayload and no default value");
137137

138138
MimeType metadataMimeType =
139-
StringUtils.hasText(setupPayload.dataMimeType())
139+
StringUtils.hasText(setupPayload.metadataMimeType())
140140
? MimeTypeUtils.parseMimeType(setupPayload.metadataMimeType())
141141
: this.defaultMetadataMimeType;
142142
Assert.notNull(dataMimeType, "No `metadataMimeType` in the ConnectionSetupPayload and no default value");

spring-integration-rsocket/src/test/java/org/springframework/integration/rsocket/config/RSocketInboundGatewayParserTests-context.xml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99

1010
<bean id="clientRSocketConnector" class="org.springframework.integration.rsocket.ClientRSocketConnector">
1111
<constructor-arg value="https://example.org"/>
12+
<property name="autoStartup" value="false"/>
1213
</bean>
1314

1415
<bean id="rsocketStrategies" class="org.mockito.Mockito" factory-method="mock">

spring-integration-rsocket/src/test/java/org/springframework/integration/rsocket/config/RSocketOutboundGatewayParserTests-context.xml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99

1010
<bean id="clientRSocketConnector" class="org.springframework.integration.rsocket.ClientRSocketConnector">
1111
<constructor-arg value="https://example.org"/>
12+
<property name="autoStartup" value="false"/>
1213
</bean>
1314

1415
<int:channel id="requestChannel"/>

0 commit comments

Comments
 (0)