|
1 | 1 | /* |
2 | | - * Copyright 2002-2024 the original author or authors. |
| 2 | + * Copyright 2002-2025 the original author or authors. |
3 | 3 | * |
4 | 4 | * Licensed under the Apache License, Version 2.0 (the "License"); |
5 | 5 | * you may not use this file except in compliance with the License. |
@@ -239,21 +239,22 @@ void buildMultipleMessages() { |
239 | 239 | assertThat(message3.getHeaders().get("foo")).isEqualTo("bar3"); |
240 | 240 | } |
241 | 241 |
|
242 | | - @Test |
243 | | - void buildReplyChannelHeaderMessage() { |
| 242 | + @Test // gh-34949 |
| 243 | + void buildMessageWithReplyChannelHeader() { |
244 | 244 | MessageHeaderAccessor headerAccessor = new MessageHeaderAccessor(); |
245 | 245 | MessageBuilder<?> messageBuilder = MessageBuilder.withPayload("payload").setHeaders(headerAccessor); |
246 | 246 |
|
247 | | - headerAccessor.setHeader("replyChannel", "foo"); |
| 247 | + headerAccessor.setHeader(MessageHeaders.REPLY_CHANNEL, "foo"); |
248 | 248 | Message<?> message1 = messageBuilder.build(); |
| 249 | + assertThat(message1.getHeaders().get(MessageHeaders.REPLY_CHANNEL)).isEqualTo("foo"); |
249 | 250 |
|
250 | 251 | headerAccessor.setHeader("hannel", 0); |
251 | 252 | Message<?> message2 = messageBuilder.build(); |
252 | | - |
253 | | - assertThat(message1.getHeaders().get("replyChannel")).isEqualTo("foo"); |
254 | 253 | assertThat(message2.getHeaders().get("hannel")).isEqualTo(0); |
255 | 254 |
|
256 | | - assertThatIllegalArgumentException().isThrownBy(() -> headerAccessor.setHeader("replyChannel", 0)); |
| 255 | + assertThatIllegalArgumentException() |
| 256 | + .isThrownBy(() -> headerAccessor.setHeader(MessageHeaders.REPLY_CHANNEL, 0)) |
| 257 | + .withMessage("'%s' header value must be a MessageChannel or String", MessageHeaders.REPLY_CHANNEL); |
257 | 258 | } |
258 | 259 |
|
259 | 260 | } |
0 commit comments