2929import javax .net .ServerSocketFactory ;
3030
3131import org .junit .jupiter .api .Test ;
32+ import org .junitpioneer .jupiter .RetryingTest ;
3233
3334import org .springframework .beans .factory .BeanFactory ;
3435import org .springframework .core .serializer .DefaultDeserializer ;
@@ -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 ,
@@ -361,7 +362,7 @@ private void testTimeoutWhileDecoding(AbstractByteArraySerializer deserializer,
361362 assertThat (message ).isNull ();
362363 }
363364
364- @ Test
365+ @ RetryingTest ( 10 )
365366 public void testTimeoutWithRawDeserializerEofIsTerminator () {
366367 ByteArrayRawSerializer serializer = new ByteArrayRawSerializer ();
367368 TcpNioServerConnectionFactory serverNio = new TcpNioServerConnectionFactory (0 );
0 commit comments