From 71c0d6d71ed04a77f1bd81e2d1899bdd57b4e3bf Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Mon, 22 Feb 2021 14:11:27 +0100 Subject: [PATCH] Fix spelling error in constant name --- .../function/rsocket/FunctionRSocketMessageHandler.java | 6 +++--- .../rsocket/RSocketAutoConfigurationRoutingTests.java | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) 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(); }; }