public static void controlBlobStore(ConnectedChannel channel, PartitionId partitionId, boolean enable)
      throws Exception {
    AdminRequest adminRequest =
        new AdminRequest(AdminRequestOrResponseType.BlobStoreControl, partitionId, 1, "clientid");
    BlobStoreControlAdminRequest controlRequest = new BlobStoreControlAdminRequest((short) 0,
        enable ? BlobStoreControlAction.StartStore : BlobStoreControlAction.StopStore, adminRequest);
    DataInputStream stream = channel.sendAndReceive(controlRequest).getInputStream();
    AdminResponse adminResponse = AdminResponse.readFrom(stream);
    releaseNettyBufUnderneathStream(stream);
    Assert.assertEquals("start/Stop store admin request should succeed", ServerErrorCode.NoError,
        adminResponse.getError());
  }
Enable or disable the BlobStore on the replica
@param channel the connection channel to the replica.
@param partitionId the partitions that the control request is targeting.
@param enable if true, enable the blob store. If false, disable the blob store
@throws Exception any exception
ambry-test-utils/src/main/java/com/github/ambry/server/ServerTestUtil.java