class ParallelGatewaySenderEventProcessor extends AbstractGatewaySenderEventProcessor {

  @Override
  public int eventQueueSize() {
    ParallelGatewaySenderQueue queue = (ParallelGatewaySenderQueue) getQueue();
    return queue == null ? 0 : queue.localSize();
  }

  protected  ParallelGatewaySenderEventProcessor(AbstractGatewaySender sender,
      ThreadsMonitoring tMonitoring, boolean cleanQueues);
  protected  ParallelGatewaySenderEventProcessor(AbstractGatewaySender sender,
      Set<Region> userRegions, int id, int nDispatcher, ThreadsMonitoring tMonitoring,
      boolean cleanQueues);

}