public List<GetBucketListReply.BucketInfo> retrieveBucketList(BucketId bucketId, String bucketSpace) throws BucketStatsException {
        GetBucketListMessage msg = new GetBucketListMessage(bucketId, bucketSpace);
        GetBucketListReply bucketListReply = sendMessage(msg, GetBucketListReply.class);
        return bucketListReply.getBuckets();
    }
@Test
    void testShouldFailOnReplyError() throws BucketStatsException {
        assertThrows(BucketStatsException.class, () -> {
            GetBucketListReply reply = new GetBucketListReply();
            reply.addError(new Error(0, "errormsg"));
            when(mockedSession.syncSend(any())).thenReturn(reply);

            createRetriever().retrieveBucketList(new BucketId(1), bucketSpace);
        });
    }