Merge pull request #21 from rsocket-broker/allow-setting-data-mime-type

Allow passing data mime type.

Author: OlgaMaciaszek

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

@@ -17,19 +17,14 @@
 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;
 
@@ -90,6 +85,7 @@ else if (key.getKey() != null) {
 
 		RSocketRequester.Builder builder = RSocketRequester.builder()
 				.setupMetadata(routeSetup.build(), MimeTypes.BROKER_FRAME_MIME_TYPE)
+				.dataMimeType(properties.getDataMimeType() != null ? properties.getDataMimeType() : null)
 				.rsocketStrategies(strategies).rsocketConnector(configurer);
 
 		//TODO: BrokerRequesterBuilderCustomizer

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

@@ -27,6 +27,7 @@
 
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.core.style.ToStringCreator;
+import org.springframework.util.MimeType;
 
 import static io.rsocket.broker.client.spring.BrokerClientProperties.CONFIG_PREFIX;
 
@@ -49,6 +50,8 @@ public class BrokerClientProperties {
 
 	private boolean failIfMissingBrokerMetadata = true;
 
+	private MimeType dataMimeType;
+
 	public BrokerClientProperties() {
 	}
 
@@ -104,6 +107,14 @@ public void setFailIfMissingBrokerMetadata(boolean failIfMissingBrokerMetadata)
 		this.failIfMissingBrokerMetadata = failIfMissingBrokerMetadata;
 	}
 
+	public MimeType getDataMimeType() {
+		return dataMimeType;
+	}
+
+	public void setDataMimeType(MimeType dataMimeType) {
+		this.dataMimeType = dataMimeType;
+	}
+
 	@Override
 	public String toString() {
 		// @formatter:off
@@ -115,6 +126,7 @@ public String toString() {
 				.append("broker", getBrokers())
 				.append("address", address)
 				.append("failIfMissingBrokerMetadata", failIfMissingBrokerMetadata)
+				.append("dataMimeType", dataMimeType)
 				.toString();
 		// @formatter:on
 	}