@Override
  public void fromData(DataInput in,
      DeserializationContext context) throws IOException, ClassNotFoundException {
    super.fromData(in, context);
    bucketId = (int) InternalDataSerializer.readSignedVL(in);
    if ((flags & HAS_BRIDGE_CONTEXT) != 0) {
      bridgeContext = DataSerializer.readObject(in);
    }
    callbackArg = DataSerializer.readObject(in);
    removeAllPRDataSize = (int) InternalDataSerializer.readUnsignedVL(in);
    removeAllPRData = new RemoveAllEntryData[removeAllPRDataSize];
    if (removeAllPRDataSize > 0) {
      for (int i = 0; i < removeAllPRDataSize; i++) {
        removeAllPRData[i] = new RemoveAllEntryData(in, null, i, context);
      }

      boolean hasTags = in.readBoolean();
      if (hasTags) {
        EntryVersionsList versionTags = EntryVersionsList.create(in);
        for (int i = 0; i < removeAllPRDataSize; i++) {
          removeAllPRData[i].versionTag = versionTags.get(i);
        }
      }
    }
  }
Sends a PartitionedRegion RemoveAllPRMessage to the recipient

@param recipient the member to which the message is sent
@param r the PartitionedRegion for which the op was performed
@return the processor used to await acknowledgement that the op was sent, or null to indicate
        that no acknowledgement will be sent
@throws ForceReattemptException if the peer is no longer available
geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/RemoveAllPRMessage.java