@Override
  protected void rebalance() {
    GatewaySenderStats statistics = sender.getStatistics();
    long startTime = statistics.startLoadBalance();
    try {
      if (dispatcher.isRemoteDispatcher()) {
        GatewaySenderEventRemoteDispatcher remoteDispatcher =
            (GatewaySenderEventRemoteDispatcher) dispatcher;
        if (remoteDispatcher.isConnectedToRemote()) {
          remoteDispatcher.stopAckReaderThread();
          remoteDispatcher.destroyConnection();
        }
      }
    } finally {
      statistics.endLoadBalance(startTime);
    }
  }
use in concurrent scenario where queue is to be shared among all the processors.
geode-wan/src/main/java/org/apache/geode/cache/wan/internal/parallel/RemoteParallelGatewaySenderEventProcessor.java