Skip to content

Commit f56c70d

Browse files
committed
Merge branch '5.1.x'
2 parents fd36d1e + c841b62 commit f56c70d

File tree

3 files changed

+13
-13
lines changed

3 files changed

+13
-13
lines changed

spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/InvocableHandlerMethod.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -127,10 +127,11 @@ public Object invoke(Message<?> message, Object... providedArgs) throws Exceptio
127127
* @since 5.1.2
128128
*/
129129
protected Object[] getMethodArgumentValues(Message<?> message, Object... providedArgs) throws Exception {
130-
if (ObjectUtils.isEmpty(getMethodParameters())) {
130+
MethodParameter[] parameters = getMethodParameters();
131+
if (ObjectUtils.isEmpty(parameters)) {
131132
return EMPTY_ARGS;
132133
}
133-
MethodParameter[] parameters = getMethodParameters();
134+
134135
Object[] args = new Object[parameters.length];
135136
for (int i = 0; i < parameters.length; i++) {
136137
MethodParameter parameter = parameters[i];

spring-web/src/main/java/org/springframework/web/method/support/InvocableHandlerMethod.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -147,10 +147,11 @@ public Object invokeForRequest(NativeWebRequest request, @Nullable ModelAndViewC
147147
protected Object[] getMethodArgumentValues(NativeWebRequest request, @Nullable ModelAndViewContainer mavContainer,
148148
Object... providedArgs) throws Exception {
149149

150-
if (ObjectUtils.isEmpty(getMethodParameters())) {
150+
MethodParameter[] parameters = getMethodParameters();
151+
if (ObjectUtils.isEmpty(parameters)) {
151152
return EMPTY_ARGS;
152153
}
153-
MethodParameter[] parameters = getMethodParameters();
154+
154155
Object[] args = new Object[parameters.length];
155156
for (int i = 0; i < parameters.length; i++) {
156157
MethodParameter parameter = parameters[i];

spring-webflux/src/main/java/org/springframework/web/reactive/result/method/InvocableHandlerMethod.java

Lines changed: 7 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -113,12 +113,9 @@ public ParameterNameDiscoverer getParameterNameDiscoverer() {
113113
}
114114

115115
/**
116-
* Configure a reactive registry. This is needed for cases where the response
117-
* is fully handled within the controller in combination with an async void
118-
* return value.
119-
* <p>By default this is an instance of {@link ReactiveAdapterRegistry} with
120-
* default settings.
121-
* @param registry the registry to use
116+
* Configure a reactive registry. This is needed for cases where the response is fully
117+
* handled within the controller in combination with an async void return value.
118+
* <p>By default this is a {@link ReactiveAdapterRegistry} with default settings.
122119
*/
123120
public void setReactiveAdapterRegistry(ReactiveAdapterRegistry registry) {
124121
this.reactiveAdapterRegistry = registry;
@@ -181,10 +178,11 @@ public Mono<HandlerResult> invoke(
181178
private Mono<Object[]> getMethodArgumentValues(
182179
ServerWebExchange exchange, BindingContext bindingContext, Object... providedArgs) {
183180

184-
if (ObjectUtils.isEmpty(getMethodParameters())) {
181+
MethodParameter[] parameters = getMethodParameters();
182+
if (ObjectUtils.isEmpty(parameters)) {
185183
return EMPTY_ARGS;
186184
}
187-
MethodParameter[] parameters = getMethodParameters();
185+
188186
List<Mono<Object>> argMonos = new ArrayList<>(parameters.length);
189187
for (MethodParameter parameter : parameters) {
190188
parameter.initParameterNameDiscovery(this.parameterNameDiscoverer);
@@ -208,7 +206,7 @@ private Mono<Object[]> getMethodArgumentValues(
208206
}
209207
}
210208
return Mono.zip(argMonos, values ->
211-
Stream.of(values).map(o -> o != NO_ARG_VALUE ? o : null).toArray());
209+
Stream.of(values).map(value -> value != NO_ARG_VALUE ? value : null).toArray());
212210
}
213211

214212
private void logArgumentErrorIfNecessary(ServerWebExchange exchange, MethodParameter parameter, Throwable ex) {

0 commit comments

Comments
 (0)