AbstractGatewaySenderEventProcessor extends LoggingThread implements GatewaySenderEventProcessor { public int eventQueueSize() { return getQueue() == null ? 0 : getQueue().size(); } AbstractGatewaySenderEventProcessor(String string,
      GatewaySender sender, ThreadsMonitoring tMonitoring); Object getRunningStateLock(); @Override int getTotalQueueSize(); void enqueueEvent(EnumListenerEvent operation, EntryEvent event,
      Object substituteValue); abstract void enqueueEvent(EnumListenerEvent operation, EntryEvent event,
      Object substituteValue, boolean isLastEventInTransaction); boolean isStopped(); boolean isPaused(); RegionQueue getQueue(); void incrementBatchId(); int eventQueueSize(); int secondaryEventQueueSize(); AbstractGatewaySender getSender(); void pauseDispatching(); void waitForDispatcherToPause(); void resumeDispatching(); boolean skipFailureLogging(Integer batchId); boolean removeEventFromFailureMap(Integer batchId); List conflate(List<GatewaySenderEventImpl> events); void checkIfPdxNeedsResend(int remotePdxSize); void handleException(); void handleSuccessBatchAck(int batchId); void handleUnSuccessBatchAck(int bId); abstract void initializeEventDispatcher(); GatewaySenderEventDispatcher getDispatcher(); Map<Integer, List<GatewaySenderEventImpl>[]> getBatchIdToEventsMap(); Map<Integer, List<GatewaySenderEventImpl>> getBatchIdToPDXEventsMap(); @Override void run(); void setRunningStatus(); void setException(GemFireException ex); Exception getException(); void stopProcessing(); void closeProcessor(); void removeCacheListener(); void logBatchFine(String message, List<GatewaySenderEventImpl> events); long getNumEventsDispatched(); void increaseNumEventsDispatched(long newEventsDispatched); void clear(PartitionedRegion pr, int bucketId); void notifyEventProcessorIfRequired(int bucketId); BlockingQueue<GatewaySenderEventImpl> getBucketTmpQueue(int bucketId); PartitionedRegion getRegion(String prRegionName); void removeShadowPR(String prRegionName); void conflateEvent(Conflatable conflatableObject, int bucketId, Long tailKey); void addShadowPartitionedRegionForUserPR(PartitionedRegion pr); void addShadowPartitionedRegionForUserRR(DistributedRegion userRegion); String printUnprocessedEvents(); String printUnprocessedTokens();  }
@Test public void eventQueueSizeReturnsZeroIfRegionQueueIsNull() { AbstractGatewaySenderEventProcessor processor = mock(AbstractGatewaySenderEventProcessor.class); doCallRealMethod().when(processor).eventQueueSize(); assertThat(processor.eventQueueSize()).isEqualTo(0); verify(queue, never()).size(); }