Enable encoding of message/x.rsocket.routing.v0 requests

wilkinsona · wilkinsona · commit 704b5fb2ee03 · 2019-06-13T12:38:15.000+01:00
Closes gh-17135
diff --git a/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/rsocket/RSocketStrategiesAutoConfiguration.java b/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/rsocket/RSocketStrategiesAutoConfiguration.java
@@ -62,7 +62,7 @@ public RSocketStrategies rSocketStrategies(ObjectProvider<RSocketStrategiesCusto
 		builder.reactiveAdapterStrategy(ReactiveAdapterRegistry.getSharedInstance());
 		customizers.orderedStream().forEach((customizer) -> customizer.customize(builder));
 		builder.decoder(StringDecoder.textPlainOnly());
-		builder.encoder(CharSequenceEncoder.textPlainOnly());
+		builder.encoder(CharSequenceEncoder.allMimeTypes());
 		builder.dataBufferFactory(new NettyDataBufferFactory(PooledByteBufAllocator.DEFAULT));
 		return builder.build();
 	}

Original file line number	Diff line number	Diff line change
`@@ -62,7 +62,7 @@ public RSocketStrategies rSocketStrategies(ObjectProvider<RSocketStrategiesCusto`
`62`	`62`	`builder.reactiveAdapterStrategy(ReactiveAdapterRegistry.getSharedInstance());`
`63`	`63`	`customizers.orderedStream().forEach((customizer) -> customizer.customize(builder));`
`64`	`64`	`builder.decoder(StringDecoder.textPlainOnly());`
`65`		`- builder.encoder(CharSequenceEncoder.textPlainOnly());`
	`65`	`+ builder.encoder(CharSequenceEncoder.allMimeTypes());`
`66`	`66`	`builder.dataBufferFactory(new NettyDataBufferFactory(PooledByteBufAllocator.DEFAULT));`
`67`	`67`	`return builder.build();`
`68`	`68`	`}`