@Override
    public boolean processData(DistroData distroData) {
        switch (distroData.getType()) {
            case ADD:
            case CHANGE:
                ClientSyncData clientSyncData = ApplicationUtils.getBean(Serializer.class)
                        .deserialize(distroData.getContent(), ClientSyncData.class);
                handlerClientSyncData(clientSyncData);
                return true;
            case DELETE:
                String deleteClientId = distroData.getDistroKey().getResourceKey();
                Loggers.DISTRO.info("[Client-Delete] Received distro client sync data {}", deleteClientId);
                clientManager.clientDisconnected(deleteClientId);
                return true;
            default:
                return false;
        }
    }
@Test
    void testProcessDataForChangeClient() {
        distroData.setType(DataOperation.CHANGE);
        assertEquals(0L, client.getRevision());
        assertEquals(0, client.getAllPublishedService().size());
        distroClientDataProcessor.processData(distroData);
        verify(clientManager).syncClientConnected(CLIENT_ID, clientSyncData.getAttributes());
        assertEquals(1L, client.getRevision());
        assertEquals(1, client.getAllPublishedService().size());
    }