public List<Subscriber> getSubscribers(String serviceName, String namespaceId, boolean aggregation) {
        if (aggregation) {
            Collection<Subscriber> result = aggregationService.getFuzzySubscribers(namespaceId, serviceName);
            return CollectionUtils.isNotEmpty(result) ? result.stream().filter(distinctByKey(Subscriber::toString))
                    .collect(Collectors.toList()) : Collections.EMPTY_LIST;
        } else {
            return new LinkedList<>(localService.getFuzzySubscribers(namespaceId, serviceName));
        }
    }
@Test
    void getSubscribersWithFalse() {
        String serviceName = "test";
        String namespaceId = "public";
        boolean aggregation = Boolean.FALSE;
        try {
            List<Subscriber> clients = new ArrayList<Subscriber>();
            Subscriber subscriber = new Subscriber("127.0.0.1:8080", "test", "app", "127.0.0.1", namespaceId, serviceName, 0);
            clients.add(subscriber);
            Mockito.when(this.local.getFuzzySubscribers(Mockito.anyString(), Mockito.anyString())).thenReturn(clients);
            List<Subscriber> list = subscribeManager.getSubscribers(serviceName, namespaceId, aggregation);
            assertNotNull(list);
            assertEquals(1, list.size());
            assertEquals("public", list.get(0).getNamespaceId());
        } catch (Exception ignored) {
        
        }
    }