@Override
    public void rollbackMigration(PartitionMigrationEvent event) {
        if (event.getMigrationEndpoint() == DESTINATION) {
            clearRingbuffersHavingLesserBackupCountThan(event.getPartitionId(), event.getCurrentReplicaIndex());
        }
    }
@Test
    public void rollbackMigration() {
        Ringbuffer ringbuffer = hz.getRingbuffer("foo");
        int partitionId = getPartitionId(hz, ringbuffer.getName());
        PartitionMigrationEvent partitionEvent = new PartitionMigrationEvent(DESTINATION, partitionId, -1, 0, UUID.randomUUID());

        service.rollbackMigration(partitionEvent);

        assertEquals(0, service.getContainers().size());
    }