public void sendAbort(DistributionManager dmgr, int windowId, DistributedMember member) {
    if (getLogger().fineEnabled()) {
      getLogger().fine("SNP: Sending ABORT to member " + member + " for window " + windowId);
    }

    if (dmgr.getDistributionManagerId().equals(member)) {
      WindowImpl<?, ?> win = (WindowImpl<?, ?>) processors.retrieve(windowId);
      if (win != null) {
        win.abort();
      }
    } else {
      FlowControlAbortMessage abort = new FlowControlAbortMessage(windowId);
      abort.setRecipient((InternalDistributedMember) member);
      dmgr.putOutgoing(abort);
    }
  }
Aborts further message processing.

@param dmgr the distribution manager
@param windowId the window
@param member the data source
geode-core/src/main/java/org/apache/geode/internal/cache/snapshot/FlowController.java