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 .core .task .SimpleAsyncTaskExecutor ;
3636import org .springframework .integration .ip .IpHeaders ;
5353@ DisabledOnOs (value = OS .MAC , disabledReason = "Multicast tests don't work on MacOS" )
5454public class DatagramPacketMulticastSendingHandlerTests implements TestApplicationContextAware {
5555
56- @ Test
56+ @ RetryingTest ( 10 )
5757 public void verifySendMulticast (MulticastCondition multicastCondition ) throws Exception {
5858 MulticastSocket socket ;
5959 try {
@@ -122,7 +122,7 @@ public void verifySendMulticast(MulticastCondition multicastCondition) throws Ex
122122 socket .close ();
123123 }
124124
125- @ Test
125+ @ RetryingTest ( 10 )
126126 public void verifySendMulticastWithAcks (MulticastCondition multicastCondition ) throws Exception {
127127 MulticastSocket socket = new MulticastSocket ();
128128 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 .context .ConfigurableApplicationContext ;
3839import org .springframework .context .support .ClassPathXmlApplicationContext ;
@@ -257,7 +258,7 @@ public void testUnicastSender() {
257258 }
258259
259260 @ SuppressWarnings ("unchecked" )
260- @ Test
261+ @ RetryingTest ( 10 )
261262 public void testMulticastReceiver (MulticastCondition multicastCondition ) throws Exception {
262263 QueueChannel channel = new QueueChannel (2 );
263264 MulticastReceivingChannelAdapter adapter =
You can’t perform that action at this time.
0 commit comments