|
32 | 32 | import org.springframework.messaging.support.ErrorMessage; |
33 | 33 | import org.springframework.messaging.support.GenericMessage; |
34 | 34 | import org.springframework.util.Assert; |
35 | | -import org.springframework.util.ObjectUtils; |
36 | 35 |
|
37 | 36 | /** |
38 | 37 | * The {@link AbstractIntegrationMessageBuilder} extension for the default logic to build message. |
@@ -64,12 +63,10 @@ public abstract class BaseMessageBuilder<T, B extends BaseMessageBuilder<T, B>> |
64 | 63 |
|
65 | 64 | private final IntegrationMessageHeaderAccessor headerAccessor; |
66 | 65 |
|
67 | | - @Nullable |
68 | | - private final Message<T> originalMessage; |
| 66 | + private final @Nullable Message<T> originalMessage; |
69 | 67 |
|
70 | 68 | private volatile boolean modified; |
71 | 69 |
|
72 | | - @SuppressWarnings("NullAway.Init") |
73 | 70 | private String @Nullable [] readOnlyHeaders; |
74 | 71 |
|
75 | 72 | protected BaseMessageBuilder(T payload, @Nullable Message<T> originalMessage) { |
@@ -287,7 +284,7 @@ public B setPriority(Integer priority) { |
287 | 284 | * @return the current {@link BaseMessageBuilder} |
288 | 285 | * @see IntegrationMessageHeaderAccessor#isReadOnly(String) |
289 | 286 | */ |
290 | | - public B readOnlyHeaders(String... readOnlyHeaders) { |
| 287 | + public B readOnlyHeaders(String @Nullable ... readOnlyHeaders) { |
291 | 288 | this.readOnlyHeaders = readOnlyHeaders != null ? Arrays.copyOf(readOnlyHeaders, readOnlyHeaders.length) : null; |
292 | 289 | if (readOnlyHeaders != null) { |
293 | 290 | this.headerAccessor.setReadOnlyHeaders(readOnlyHeaders); |
@@ -319,9 +316,9 @@ public Message<T> build() { |
319 | 316 | } |
320 | 317 |
|
321 | 318 | private boolean containsReadOnly(MessageHeaders headers) { |
322 | | - if (!ObjectUtils.isEmpty(this.readOnlyHeaders)) { |
| 319 | + if (this.readOnlyHeaders != null) { |
323 | 320 | for (String readOnly : this.readOnlyHeaders) { |
324 | | - if (readOnly != null && headers.containsKey(readOnly)) { |
| 321 | + if (headers.containsKey(readOnly)) { |
325 | 322 | return true; |
326 | 323 | } |
327 | 324 | } |
|
0 commit comments