Allow passing data mime type.

Author: OlgaMaciaszek

rsocket-broker-client-spring/src/main/java/io/rsocket/broker/client/spring/BrokerClientAutoConfiguration.java

@@ -17,23 +17,19 @@
 package io.rsocket.broker.client.spring;
 
 import java.net.URI;
-import java.util.Collections;
-import java.util.List;
 
 import io.rsocket.RSocket;
 import io.rsocket.broker.common.spring.ClientTransportFactory;
 import io.rsocket.broker.common.spring.DefaultClientTransportFactory;
 import io.rsocket.broker.common.spring.MimeTypes;
 import io.rsocket.broker.frames.RouteSetup;
-import io.rsocket.loadbalance.LoadbalanceTarget;
-import io.rsocket.loadbalance.RoundRobinLoadbalanceStrategy;
 import io.rsocket.transport.ClientTransport;
 import reactor.core.Disposable;
-import reactor.core.publisher.Flux;
 import reactor.core.publisher.Sinks;
 import reactor.core.publisher.Sinks.One;
 
 import org.springframework.beans.factory.ObjectProvider;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.autoconfigure.AutoConfigureAfter;
 import org.springframework.boot.autoconfigure.AutoConfigureBefore;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
@@ -73,7 +69,7 @@ public BrokerClientProperties brokerClientProperties() {
 	@ConditionalOnMissingBean
 	public BrokerRSocketRequesterBuilder brokerRSocketRequesterBuilder(
 			RSocketConnectorConfigurer configurer, RSocketStrategies strategies,
-			BrokerClientProperties properties) {
+			BrokerClientProperties properties, @Autowired(required = false) BrokerClientMimeTypeSupplier brokerClientMimeTypeSupplier) {
 		RouteSetup.Builder routeSetup = RouteSetup.from(properties.getRouteId(),
 				properties.getServiceName());
 		properties.getTags().forEach((key, value) -> {
@@ -90,6 +86,7 @@ else if (key.getKey() != null) {
 
 		RSocketRequester.Builder builder = RSocketRequester.builder()
 				.setupMetadata(routeSetup.build(), MimeTypes.BROKER_FRAME_MIME_TYPE)
+				.dataMimeType(brokerClientMimeTypeSupplier != null ? brokerClientMimeTypeSupplier.get() : null)
 				.rsocketStrategies(strategies).rsocketConnector(configurer);
 
 		//TODO: BrokerRequesterBuilderCustomizer

rsocket-broker-client-spring/src/main/java/io/rsocket/broker/client/spring/BrokerClientMimeTypeSupplier.java

@@ -0,0 +1,27 @@
+/*
+ * Copyright 2022-2022 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package io.rsocket.broker.client.spring;
+
+import java.util.function.Supplier;
+
+import org.springframework.util.MimeType;
+
+/**
+ * Allows setting data mime type for communication via broker.
+ */
+public interface BrokerClientMimeTypeSupplier extends Supplier<MimeType> {
+}