Some polishing for RSocket support

This commit is contained in:
Artem Bilan
2019-06-18 15:16:34 -04:00
parent 244e5942df
commit 36c14ef179
3 changed files with 3 additions and 1 deletions

View File

@@ -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");

View File

@@ -9,6 +9,7 @@
<bean id="clientRSocketConnector" class="org.springframework.integration.rsocket.ClientRSocketConnector">
<constructor-arg value="https://example.org"/>
<property name="autoStartup" value="false"/>
</bean>
<bean id="rsocketStrategies" class="org.mockito.Mockito" factory-method="mock">

View File

@@ -9,6 +9,7 @@
<bean id="clientRSocketConnector" class="org.springframework.integration.rsocket.ClientRSocketConnector">
<constructor-arg value="https://example.org"/>
<property name="autoStartup" value="false"/>
</bean>
<int:channel id="requestChannel"/>