geode-wan/src/test/java/org/apache/geode/internal/cache/wan/WANTestBase.java
public static void validateQueueClosedForConcurrentSerialGatewaySender(final String senderId) {
    Set<GatewaySender> senders = cache.getGatewaySenders();
    GatewaySender sender = null;
    for (GatewaySender s : senders) {
      if (s.getId().equals(senderId)) {
        sender = s;
        break;
      }
    }
    final Set<RegionQueue> regionQueue;
    if (sender instanceof AbstractGatewaySender) {
      regionQueue = ((AbstractGatewaySender) sender).getQueuesForConcurrentSerialGatewaySender();
    } else {
      regionQueue = null;
    }
    assertEquals(null, regionQueue);
  }
// Ensure that the sender's queue(s) have been closed.
Ensure that the sender's queue(s) have been closed.
Ensure that the sender ' s queue ( s ) have been closed .
public static void validateQueueClosedForConcurrentSerialGatewaySender(final String senderId) {
    Set<GatewaySender> senders = cache.getGatewaySenders();
    GatewaySender sender = null;
    for (GatewaySender s : senders) {
      if (s.getId().equals(senderId)) {
        sender = s;
        break;
      }
    }
    final Set<RegionQueue> regionQueue;
    if (sender instanceof AbstractGatewaySender) {
      regionQueue = ((AbstractGatewaySender) sender).getQueuesForConcurrentSerialGatewaySender();
    } else {
      regionQueue = null;
    }
    assertEquals(null, regionQueue);
  }
public static void validateQueueClosedForConcurrentSerialGatewaySender ( final String senderId ) { Set < GatewaySender > senders = cache . getGatewaySenders ( ) ; GatewaySender sender = null ; for ( GatewaySender s : senders ) { if ( s . getId ( ) . equals ( senderId ) ) { sender = s ; break ; } } final Set < RegionQueue > regionQueue ; if ( sender instanceof AbstractGatewaySender ) { regionQueue = ( ( AbstractGatewaySender ) sender ) . getQueuesForConcurrentSerialGatewaySender ( ) ; } else { regionQueue = null ; } assertEquals ( null , regionQueue ) ; }
Ensure that the sender's queue(s) have been closed.
Ensure that the sender ' s queue ( s ) have been closed .