Skip to content

Commit 427669a

Browse files
committed
Fix spelling error in constant name
1 parent 3869319 commit 427669a

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

spring-cloud-function-rsocket/src/main/java/org/springframework/cloud/function/rsocket/FunctionRSocketMessageHandler.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@
7676
*/
7777
class FunctionRSocketMessageHandler extends RSocketMessageHandler {
7878

79-
public static final String RECONSILED_LOOKUP_DESTINATION_HEADER = "reconsiledLookupDestination";
79+
public static final String RECONCILED_LOOKUP_DESTINATION_HEADER = "reconciledLookupDestination";
8080

8181
private final FunctionCatalog functionCatalog;
8282

@@ -137,7 +137,7 @@ public Mono<Void> handleMessage(Message<?> message) throws MessagingException {
137137

138138
@Override
139139
protected RouteMatcher.Route getDestination(Message<?> message) {
140-
RouteMatcher.Route reconsiledDestination = (RouteMatcher.Route) message.getHeaders().get(RECONSILED_LOOKUP_DESTINATION_HEADER);
140+
RouteMatcher.Route reconsiledDestination = (RouteMatcher.Route) message.getHeaders().get(RECONCILED_LOOKUP_DESTINATION_HEADER);
141141
return reconsiledDestination == null ? super.getDestination(message) : reconsiledDestination;
142142
}
143143

@@ -206,7 +206,7 @@ private void updateMessageHeaders(Message<?> message, String destination) {
206206
Map<String, Object> headersMap = (Map<String, Object>) ReflectionUtils
207207
.getField(this.headersField, message.getHeaders());
208208
PathPatternRouteMatcher matcher = new PathPatternRouteMatcher();
209-
headersMap.put(RECONSILED_LOOKUP_DESTINATION_HEADER, matcher.parseRoute(destination));
209+
headersMap.put(RECONCILED_LOOKUP_DESTINATION_HEADER, matcher.parseRoute(destination));
210210
}
211211

212212
protected static final class MessageHandlerMethodArgumentResolver implements SyncHandlerMethodArgumentResolver {

spring-cloud-function-rsocket/src/test/java/org/springframework/cloud/function/rsocket/RSocketAutoConfigurationRoutingTests.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -190,7 +190,7 @@ public Function<Message<String>, String> uppercaseMessage() {
190190
assertThat(msg.getHeaders()
191191
.get(DestinationPatternsMessageCondition.LOOKUP_DESTINATION_HEADER)).toString().equals("uppercase");
192192
assertThat(msg.getHeaders()
193-
.get(FunctionRSocketMessageHandler.RECONSILED_LOOKUP_DESTINATION_HEADER)).toString().equals(RoutingFunction.FUNCTION_NAME);
193+
.get(FunctionRSocketMessageHandler.RECONCILED_LOOKUP_DESTINATION_HEADER)).toString().equals(RoutingFunction.FUNCTION_NAME);
194194
return msg.getPayload().toUpperCase();
195195
};
196196
}

0 commit comments

Comments
 (0)