Skip to content

Commit feadc9b

Browse files
artembilanspring-builds
authored andcommitted
RetryingTest for DeserializationTests
Also fix `foobar` in that test class (cherry picked from commit ec669c0)
1 parent 9052fb6 commit feadc9b

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/serializer/DeserializationTests.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@
2929
import javax.net.ServerSocketFactory;
3030

3131
import org.junit.jupiter.api.Test;
32+
import org.junitpioneer.jupiter.RetryingTest;
3233

3334
import org.springframework.core.serializer.DefaultDeserializer;
3435
import org.springframework.core.task.SimpleAsyncTaskExecutor;
@@ -257,7 +258,7 @@ public void canDeserializeMultipleSubsequentTerminators() throws IOException {
257258
@Test
258259
public void deserializationEvents() {
259260
doDeserialize(new ByteArrayCrLfSerializer(), "CRLF not found before max message length: 5");
260-
doDeserialize(new ByteArrayLengthHeaderSerializer(), "Message length 1718579042 exceeds max message length: 5");
261+
doDeserialize(new ByteArrayLengthHeaderSerializer(), "Message length 1952805748 exceeds max message length: 5");
261262
TcpDeserializationExceptionEvent event = doDeserialize(new ByteArrayLengthHeaderSerializer(),
262263
"Stream closed after 3 of 4", new byte[] {0, 0, 0}, 5); // closed during header read
263264
assertThat(event.getOffset()).isEqualTo(-1);
@@ -277,7 +278,7 @@ public void deserializationEvents() {
277278
}
278279

279280
private TcpDeserializationExceptionEvent doDeserialize(AbstractByteArraySerializer deser, String expectedMessage) {
280-
return doDeserialize(deser, expectedMessage, "foobar".getBytes(), 5);
281+
return doDeserialize(deser, expectedMessage, "test_test".getBytes(), 5);
281282
}
282283

283284
private TcpDeserializationExceptionEvent doDeserialize(AbstractByteArraySerializer deser, String expectedMessage,
@@ -369,7 +370,7 @@ private void testTimeoutWhileDecoding(AbstractByteArraySerializer deserializer,
369370
assertThat(message).isNull();
370371
}
371372

372-
@Test
373+
@RetryingTest(10)
373374
public void testTimeoutWithRawDeserializerEofIsTerminator() {
374375
ByteArrayRawSerializer serializer = new ByteArrayRawSerializer();
375376
TcpNioServerConnectionFactory serverNio = getTcpNioServerConnectionFactory(0);

0 commit comments

Comments
 (0)