diff --git a/spring-cloud-function-rsocket/src/main/java/org/springframework/cloud/function/rsocket/FunctionRSocketMessageHandler.java b/spring-cloud-function-rsocket/src/main/java/org/springframework/cloud/function/rsocket/FunctionRSocketMessageHandler.java index a7774b544..a9d0502ad 100644 --- a/spring-cloud-function-rsocket/src/main/java/org/springframework/cloud/function/rsocket/FunctionRSocketMessageHandler.java +++ b/spring-cloud-function-rsocket/src/main/java/org/springframework/cloud/function/rsocket/FunctionRSocketMessageHandler.java @@ -76,7 +76,7 @@ import org.springframework.web.util.pattern.PathPatternRouteMatcher; */ class FunctionRSocketMessageHandler extends RSocketMessageHandler { - public static final String RECONSILED_LOOKUP_DESTINATION_HEADER = "reconsiledLookupDestination"; + public static final String RECONCILED_LOOKUP_DESTINATION_HEADER = "reconciledLookupDestination"; private final FunctionCatalog functionCatalog; @@ -137,7 +137,7 @@ class FunctionRSocketMessageHandler extends RSocketMessageHandler { @Override protected RouteMatcher.Route getDestination(Message message) { - RouteMatcher.Route reconsiledDestination = (RouteMatcher.Route) message.getHeaders().get(RECONSILED_LOOKUP_DESTINATION_HEADER); + RouteMatcher.Route reconsiledDestination = (RouteMatcher.Route) message.getHeaders().get(RECONCILED_LOOKUP_DESTINATION_HEADER); return reconsiledDestination == null ? super.getDestination(message) : reconsiledDestination; } @@ -206,7 +206,7 @@ class FunctionRSocketMessageHandler extends RSocketMessageHandler { Map headersMap = (Map) ReflectionUtils .getField(this.headersField, message.getHeaders()); PathPatternRouteMatcher matcher = new PathPatternRouteMatcher(); - headersMap.put(RECONSILED_LOOKUP_DESTINATION_HEADER, matcher.parseRoute(destination)); + headersMap.put(RECONCILED_LOOKUP_DESTINATION_HEADER, matcher.parseRoute(destination)); } protected static final class MessageHandlerMethodArgumentResolver implements SyncHandlerMethodArgumentResolver { diff --git a/spring-cloud-function-rsocket/src/test/java/org/springframework/cloud/function/rsocket/RSocketAutoConfigurationRoutingTests.java b/spring-cloud-function-rsocket/src/test/java/org/springframework/cloud/function/rsocket/RSocketAutoConfigurationRoutingTests.java index 287f9b68a..5d25c05fc 100644 --- a/spring-cloud-function-rsocket/src/test/java/org/springframework/cloud/function/rsocket/RSocketAutoConfigurationRoutingTests.java +++ b/spring-cloud-function-rsocket/src/test/java/org/springframework/cloud/function/rsocket/RSocketAutoConfigurationRoutingTests.java @@ -190,7 +190,7 @@ public class RSocketAutoConfigurationRoutingTests { assertThat(msg.getHeaders() .get(DestinationPatternsMessageCondition.LOOKUP_DESTINATION_HEADER)).toString().equals("uppercase"); assertThat(msg.getHeaders() - .get(FunctionRSocketMessageHandler.RECONSILED_LOOKUP_DESTINATION_HEADER)).toString().equals(RoutingFunction.FUNCTION_NAME); + .get(FunctionRSocketMessageHandler.RECONCILED_LOOKUP_DESTINATION_HEADER)).toString().equals(RoutingFunction.FUNCTION_NAME); return msg.getPayload().toUpperCase(); }; }