File tree Expand file tree Collapse file tree
spring-integration-ip/src/test/java/org/springframework/integration/ip/udp Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2828import java .util .concurrent .TimeUnit ;
2929import java .util .concurrent .atomic .AtomicInteger ;
3030
31- import org .junit .jupiter .api .Test ;
3231import org .junit .jupiter .api .condition .DisabledOnOs ;
3332import org .junit .jupiter .api .condition .OS ;
33+ import org .junitpioneer .jupiter .RetryingTest ;
3434
3535import org .springframework .beans .factory .BeanFactory ;
3636import org .springframework .core .task .SimpleAsyncTaskExecutor ;
5252@ DisabledOnOs (value = OS .MAC , disabledReason = "Multicast tests don't work on MacOS" )
5353public class DatagramPacketMulticastSendingHandlerTests {
5454
55- @ Test
55+ @ RetryingTest ( 10 )
5656 public void verifySendMulticast (MulticastCondition multicastCondition ) throws Exception {
5757 MulticastSocket socket ;
5858 try {
@@ -121,7 +121,7 @@ public void verifySendMulticast(MulticastCondition multicastCondition) throws Ex
121121 socket .close ();
122122 }
123123
124- @ Test
124+ @ RetryingTest ( 10 )
125125 public void verifySendMulticastWithAcks (MulticastCondition multicastCondition ) throws Exception {
126126 MulticastSocket socket = new MulticastSocket ();
127127 final int testPort = socket .getLocalPort ();
Original file line number Diff line number Diff line change 3333import org .junit .jupiter .api .Test ;
3434import org .junit .jupiter .api .condition .DisabledOnOs ;
3535import org .junit .jupiter .api .condition .OS ;
36+ import org .junitpioneer .jupiter .RetryingTest ;
3637
3738import org .springframework .beans .factory .BeanFactory ;
3839import org .springframework .context .ConfigurableApplicationContext ;
@@ -245,7 +246,7 @@ public void testUnicastSender() {
245246 }
246247
247248 @ SuppressWarnings ("unchecked" )
248- @ Test
249+ @ RetryingTest ( 10 )
249250 public void testMulticastReceiver (MulticastCondition multicastCondition ) throws Exception {
250251 QueueChannel channel = new QueueChannel (2 );
251252 MulticastReceivingChannelAdapter adapter =
You can’t perform that action at this time.
0 commit comments