DistributionMessage implements Message<InternalDistributedMember>, Cloneable { public void setReplySender(ReplySender acker) { this.acker = acker; } protected  DistributionMessage(); static byte getNumBits(final int maxValue); void setDoDecMessagesBeingReceived(boolean v); void setReplySender(ReplySender acker); ReplySender getReplySender(DistributionManager dm); boolean isDirectAck(); boolean orderedDelivery(); void setRecipient(InternalDistributedMember recipient); void setMulticast(boolean v); boolean getMulticast(); boolean sendViaUDP(); @Override void setRecipients(Collection recipients); @Override void registerProcessor(); @Override boolean isHighPriority(); @Override List<InternalDistributedMember> getRecipients(); void resetRecipients(); boolean forAll(); String getRecipientsDescription(); InternalDistributedMember getSender(); @Override void setSender(InternalDistributedMember _sender); abstract int getProcessorType(); static boolean isMembershipMessengerThread(); static boolean isMembershipMessengerThreadName(String thrname); boolean getInlineProcess(); void setBreadcrumbsInReceiver(); void setBreadcrumbsInSender(); EventID getEventID(); void reset(); @Override void toData(DataOutput out,
      SerializationContext context); @Override void fromData(DataInput in,
      DeserializationContext context); long getTimestamp(); long resetTimestamp(); void setBytesRead(int bytesRead); int getBytesRead(); void setSharedReceiver(boolean v); boolean isSharedReceiver(); ConflationKey getConflationKey(); int getProcessorId(); boolean isSevereAlertCompatible(); boolean isInternal(); @Override boolean dropMessageWhenMembershipIsPlayingDead(); boolean containsRegionContentChange(); String getShortClassName(); @Override String toString(); @Override KnownVersion[] getSerializationVersions();  }
@Test public void shouldBeMockable() throws Exception { DistributionMessage mockDistributionMessage = mock(DistributionMessage.class); ReplySender mockReplySender = mock(ReplySender.class); mockDistributionMessage.setReplySender(mockReplySender); verify(mockDistributionMessage, times(1)).setReplySender(mockReplySender); }