diff --git a/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/integration/IntegrationAutoConfiguration.java b/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/integration/IntegrationAutoConfiguration.java index a493add9d28..e9f531efbbc 100644 --- a/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/integration/IntegrationAutoConfiguration.java +++ b/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/integration/IntegrationAutoConfiguration.java @@ -194,7 +194,7 @@ public class IntegrationAutoConfiguration { IntegrationProperties integrationProperties) { RSocketMessageHandler messageHandler = new ServerRSocketMessageHandler( - integrationProperties.getRSocket().getServer().isMessageMappingEnabled()); + integrationProperties.getRsocket().getServer().isMessageMappingEnabled()); messageHandler.setRSocketStrategies(rSocketStrategies); return messageHandler; } @@ -216,7 +216,7 @@ public class IntegrationAutoConfiguration { public ClientRSocketConnector clientRSocketConnector(IntegrationProperties integrationProperties, RSocketStrategies rSocketStrategies) { - IntegrationProperties.RSocket.Client client = integrationProperties.getRSocket().getClient(); + IntegrationProperties.RSocket.Client client = integrationProperties.getRsocket().getClient(); ClientRSocketConnector clientRSocketConnector = (client.getUri() != null) ? new ClientRSocketConnector(client.getUri()) : new ClientRSocketConnector(client.getHost(), client.getPort()); diff --git a/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/integration/IntegrationProperties.java b/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/integration/IntegrationProperties.java index a936e926344..1e8c0c9fb38 100644 --- a/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/integration/IntegrationProperties.java +++ b/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/integration/IntegrationProperties.java @@ -40,7 +40,7 @@ public class IntegrationProperties { return this.jdbc; } - public RSocket getRSocket() { + public RSocket getRsocket() { return this.rsocket; }