@Override
  public void initializeEventDispatcher() {
    if (logger.isDebugEnabled()) {
      logger.debug(" Creating the GatewayEventRemoteDispatcher");
    }
    if (sender.getRemoteDSId() != GatewaySender.DEFAULT_DISTRIBUTED_SYSTEM_ID) {
      dispatcher = new GatewaySenderEventRemoteDispatcher(this);
    }
  }
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