DeposePrimaryBucketMessage extends PartitionMessage { @Override protected boolean operateOnPartitionedRegion(ClusterDistributionManager dm, PartitionedRegion region, long startTime) throws ForceReattemptException { BucketAdvisor bucketAdvisor = region.getRegionAdvisor().getBucketAdvisor(this.bucketId); bucketAdvisor.deposePrimary(); region.getPrStats().endPartitionMessagesProcessing(startTime); DeposePrimaryBucketReplyMessage.send(getSender(), getProcessorId(), dm, (ReplyException) null); return false; } DeposePrimaryBucketMessage(); private  DeposePrimaryBucketMessage(InternalDistributedMember recipient, int regionId,
      ReplyProcessor21 processor, int bucketId);  DeposePrimaryBucketMessage(DataInput in); static DeposePrimaryBucketResponse send(InternalDistributedMember recipient,
      PartitionedRegion region, int bucketId); @Override boolean isSevereAlertCompatible(); @Override int getDSFID(); @Override void fromData(DataInput in,
      DeserializationContext context); @Override void toData(DataOutput out,
      SerializationContext context);  }
@Test public void shouldBeMockable() throws Exception { DeposePrimaryBucketMessage mockDeposePrimaryBucketMessage = mock(DeposePrimaryBucketMessage.class); ClusterDistributionManager mockDistributionManager = mock(ClusterDistributionManager.class); PartitionedRegion mockPartitionedRegion = mock(PartitionedRegion.class); long startTime = System.currentTimeMillis(); when(mockDeposePrimaryBucketMessage.operateOnPartitionedRegion(eq(mockDistributionManager), eq(mockPartitionedRegion), eq(startTime))).thenReturn(true); assertThat(mockDeposePrimaryBucketMessage.operateOnPartitionedRegion(mockDistributionManager, mockPartitionedRegion, startTime)).isTrue(); }