| | |
| | | } |
| | | |
| | | @Test |
| | | public void shouldHideOfflineCollectors() throws Exception |
| | | public void shouldReturnOfflineUnregisteredCollectors() throws Exception |
| | | { |
| | | try (BtsDevelopmentSimulator simulator = new BtsDevelopmentSimulator(0)) |
| | | { |
| | |
| | | |
| | | List<DiscoveredCollectorVo> result = service.selectDiscoveredCollectorList(); |
| | | |
| | | assertEquals(0, result.size()); |
| | | assertEquals(1, result.size()); |
| | | assertEquals("dev-sim-collector-1", result.get(0).getDeviceCode()); |
| | | assertEquals("离线", result.get(0).getOnlineStatus()); |
| | | } |
| | | } |
| | | |
| | |
| | | DevelopmentCollectorDiscoveryService service = |
| | | new DevelopmentCollectorDiscoveryService(store, collectorService); |
| | | TCollectorMapper collectorMapper = mock(TCollectorMapper.class); |
| | | simulator.updateCollector(1, "127.0.1.2", 4, false); |
| | | new DevelopmentCollectorStatusSynchronizer(simulator, store, collectorMapper).synchronizeOnlineStatus(); |
| | | when(collectorService.selectRegisteredCollectorCodes()) |
| | | .thenReturn(Set.of("dev-sim-collector-1")) |