Skip to content

Commit 0de13d8

Browse files
mjd507mjd507
committed
Fix broken test in spring-integration-stream
Signed-off-by: Jiandong Ma <[email protected]>
1 parent 7815c82 commit 0de13d8

File tree

2 files changed

+17
-2
lines changed

2 files changed

+17
-2
lines changed

‎spring-integration-stream/src/test/java/org/springframework/integration/stream/ByteStreamWritingMessageHandlerTests.java‎

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright 2002-2024 the original author or authors.
2+
* Copyright 2002-2025 the original author or authors.
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.
@@ -92,6 +92,7 @@ public void singleString() {
9292
public void maxMessagesPerTaskSameAsMessageCount() {
9393
endpoint.setTrigger(trigger);
9494
endpoint.setMaxMessagesPerPoll(3);
95+
endpoint.afterPropertiesSet();
9596
channel.send(new GenericMessage<byte[]>(new byte[] {1, 2, 3}), 0);
9697
channel.send(new GenericMessage<byte[]>(new byte[] {4, 5, 6}), 0);
9798
channel.send(new GenericMessage<byte[]>(new byte[] {7, 8, 9}), 0);
@@ -108,6 +109,7 @@ public void maxMessagesPerTaskSameAsMessageCount() {
108109
public void maxMessagesPerTaskLessThanMessageCount() {
109110
endpoint.setTrigger(trigger);
110111
endpoint.setMaxMessagesPerPoll(2);
112+
endpoint.afterPropertiesSet();
111113
channel.send(new GenericMessage<byte[]>(new byte[] {1, 2, 3}), 0);
112114
channel.send(new GenericMessage<byte[]>(new byte[] {4, 5, 6}), 0);
113115
channel.send(new GenericMessage<byte[]>(new byte[] {7, 8, 9}), 0);
@@ -124,6 +126,7 @@ public void maxMessagesPerTaskExceedsMessageCount() {
124126
endpoint.setTrigger(trigger);
125127
endpoint.setMaxMessagesPerPoll(5);
126128
endpoint.setReceiveTimeout(0);
129+
endpoint.afterPropertiesSet();
127130
channel.send(new GenericMessage<byte[]>(new byte[] {1, 2, 3}), 0);
128131
channel.send(new GenericMessage<byte[]>(new byte[] {4, 5, 6}), 0);
129132
channel.send(new GenericMessage<byte[]>(new byte[] {7, 8, 9}), 0);
@@ -140,6 +143,7 @@ public void testMaxMessagesLessThanMessageCountWithMultipleDispatches() {
140143
endpoint.setTrigger(trigger);
141144
endpoint.setMaxMessagesPerPoll(2);
142145
endpoint.setReceiveTimeout(0);
146+
endpoint.afterPropertiesSet();
143147
channel.send(new GenericMessage<byte[]>(new byte[] {1, 2, 3}), 0);
144148
channel.send(new GenericMessage<byte[]>(new byte[] {4, 5, 6}), 0);
145149
channel.send(new GenericMessage<byte[]>(new byte[] {7, 8, 9}), 0);
@@ -164,6 +168,7 @@ public void testMaxMessagesExceedsMessageCountWithMultipleDispatches() {
164168
endpoint.setTrigger(trigger);
165169
endpoint.setMaxMessagesPerPoll(5);
166170
endpoint.setReceiveTimeout(0);
171+
endpoint.afterPropertiesSet();
167172
channel.send(new GenericMessage<byte[]>(new byte[] {1, 2, 3}), 0);
168173
channel.send(new GenericMessage<byte[]>(new byte[] {4, 5, 6}), 0);
169174
channel.send(new GenericMessage<byte[]>(new byte[] {7, 8, 9}), 0);
@@ -187,6 +192,7 @@ public void testStreamResetBetweenDispatches() {
187192
endpoint.setMaxMessagesPerPoll(2);
188193
endpoint.setTrigger(trigger);
189194
endpoint.setReceiveTimeout(0);
195+
endpoint.afterPropertiesSet();
190196
channel.send(new GenericMessage<byte[]>(new byte[] {1, 2, 3}), 0);
191197
channel.send(new GenericMessage<byte[]>(new byte[] {4, 5, 6}), 0);
192198
channel.send(new GenericMessage<byte[]>(new byte[] {7, 8, 9}), 0);
@@ -210,6 +216,7 @@ public void testStreamWriteBetweenDispatches() throws IOException {
210216
endpoint.setTrigger(trigger);
211217
endpoint.setMaxMessagesPerPoll(2);
212218
endpoint.setReceiveTimeout(0);
219+
endpoint.afterPropertiesSet();
213220
channel.send(new GenericMessage<byte[]>(new byte[] {1, 2, 3}), 0);
214221
channel.send(new GenericMessage<byte[]>(new byte[] {4, 5, 6}), 0);
215222
channel.send(new GenericMessage<byte[]>(new byte[] {7, 8, 9}), 0);

‎spring-integration-stream/src/test/java/org/springframework/integration/stream/CharacterStreamWritingMessageHandlerTests.java‎

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright 2002-2024 the original author or authors.
2+
* Copyright 2002-2025 the original author or authors.
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.
@@ -85,6 +85,7 @@ public void singleString() {
8585
public void twoStringsAndNoNewLinesByDefault() {
8686
endpoint.setMaxMessagesPerPoll(1);
8787
endpoint.setTrigger(trigger);
88+
endpoint.afterPropertiesSet();
8889
channel.send(new GenericMessage<>("foo"), 0);
8990
channel.send(new GenericMessage<>("bar"), 0);
9091
endpoint.start();
@@ -103,6 +104,7 @@ public void twoStringsWithNewLines() {
103104
handler.setShouldAppendNewLine(true);
104105
endpoint.setTrigger(trigger);
105106
endpoint.setMaxMessagesPerPoll(1);
107+
endpoint.afterPropertiesSet();
106108
channel.send(new GenericMessage<>("foo"), 0);
107109
channel.send(new GenericMessage<>("bar"), 0);
108110
endpoint.start();
@@ -121,6 +123,7 @@ public void twoStringsWithNewLines() {
121123
public void maxMessagesPerTaskSameAsMessageCount() {
122124
endpoint.setTrigger(trigger);
123125
endpoint.setMaxMessagesPerPoll(2);
126+
endpoint.afterPropertiesSet();
124127
channel.send(new GenericMessage<>("foo"), 0);
125128
channel.send(new GenericMessage<>("bar"), 0);
126129
endpoint.start();
@@ -134,10 +137,12 @@ public void maxMessagesPerTaskExceedsMessageCountWithAppendedNewLines() {
134137
endpoint.setTrigger(trigger);
135138
endpoint.setMaxMessagesPerPoll(10);
136139
endpoint.setReceiveTimeout(0);
140+
endpoint.afterPropertiesSet();
137141
handler.setShouldAppendNewLine(true);
138142
channel.send(new GenericMessage<>("foo"), 0);
139143
channel.send(new GenericMessage<>("bar"), 0);
140144
endpoint.start();
145+
endpoint.afterPropertiesSet();
141146
trigger.await();
142147
endpoint.stop();
143148
String newLine = System.getProperty("line.separator");
@@ -148,6 +153,7 @@ public void maxMessagesPerTaskExceedsMessageCountWithAppendedNewLines() {
148153
public void singleNonStringObject() {
149154
endpoint.setTrigger(trigger);
150155
endpoint.setMaxMessagesPerPoll(1);
156+
endpoint.afterPropertiesSet();
151157
TestObject testObject = new TestObject("foo");
152158
channel.send(new GenericMessage<>(testObject));
153159
endpoint.start();
@@ -161,6 +167,7 @@ public void twoNonStringObjectWithOutNewLines() {
161167
endpoint.setReceiveTimeout(0);
162168
endpoint.setTrigger(trigger);
163169
endpoint.setMaxMessagesPerPoll(2);
170+
endpoint.afterPropertiesSet();
164171
TestObject testObject1 = new TestObject("foo");
165172
TestObject testObject2 = new TestObject("bar");
166173
channel.send(new GenericMessage<>(testObject1), 0);
@@ -177,6 +184,7 @@ public void twoNonStringObjectWithNewLines() {
177184
endpoint.setReceiveTimeout(0);
178185
endpoint.setMaxMessagesPerPoll(2);
179186
endpoint.setTrigger(trigger);
187+
endpoint.afterPropertiesSet();
180188
TestObject testObject1 = new TestObject("foo");
181189
TestObject testObject2 = new TestObject("bar");
182190
channel.send(new GenericMessage<>(testObject1), 0);

0 commit comments

Comments
 (0)