RemoteRemoveAllMessage extends RemoteOperationMessageWithDirectReply { @Override public void fromData(DataInput in, DeserializationContext context) throws IOException, ClassNotFoundException { super.fromData(in, context); this.eventId = (EventID) DataSerializer.readObject(in); this.callbackArg = DataSerializer.readObject(in); this.posDup = (flags & POS_DUP) != 0; if ((flags & HAS_BRIDGE_CONTEXT) != 0) { this.bridgeContext = DataSerializer.readObject(in); } this.removeAllDataCount = (int) InternalDataSerializer.readUnsignedVL(in); this.removeAllData = new RemoveAllEntryData[removeAllDataCount]; if (this.removeAllDataCount > 0) { final KnownVersion version = StaticSerialization.getVersionForDataStreamOrNull(in); final ByteArrayDataInput bytesIn = new ByteArrayDataInput(); for (int i = 0; i < this.removeAllDataCount; i++) { this.removeAllData[i] = new RemoveAllEntryData(in, this.eventId, i, context); } boolean hasTags = in.readBoolean(); if (hasTags) { EntryVersionsList versionTags = EntryVersionsList.create(in); for (int i = 0; i < this.removeAllDataCount; i++) { this.removeAllData[i].versionTag = versionTags.get(i); } } } } RemoteRemoveAllMessage(EntryEventImpl event, DistributedMember recipient, DirectReplyProcessor p,
      RemoveAllEntryData[] removeAllData, int removeAllDataCount, boolean useOriginRemote,
      boolean possibleDuplicate);  RemoteRemoveAllMessage(); void addEntry(RemoveAllEntryData entry); int getSize(); static boolean distribute(EntryEventImpl event, RemoveAllEntryData[] data, int dataCount); static RemoveAllResponse send(DistributedMember recipient, EntryEventImpl event,
      RemoveAllEntryData[] removeAllData, int removeAllDataCount, boolean useOriginRemote,
      boolean possibleDuplicate); void setBridgeContext(ClientProxyMembershipID contx); @Override int getDSFID(); @Override void fromData(DataInput in,
      DeserializationContext context); @Override void toData(DataOutput out,
      SerializationContext context); @Override EventID getEventID(); boolean doLocalRemoveAll(final LocalRegion r, final InternalDistributedMember eventSender);  }
@Test public void shouldBeMockable() throws Exception { RemoteRemoveAllMessage mockRemoteRemoveAllMessage = mock(RemoteRemoveAllMessage.class); DataInput mockDataInput = mock(DataInput.class); mockRemoteRemoveAllMessage.fromData(mockDataInput, null); verify(mockRemoteRemoveAllMessage, times(1)).fromData(mockDataInput, null); }