@Override
    public int getProcessorId() {
      return processorId;
    }
Overridden to wait for messages being currently processed: This situation can come about if a
member departs while we are still processing data from that member
geode-core/src/main/java/org/apache/geode/distributed/internal/streaming/StreamingOperation.java