@Test public void should_not_detect_on_trigger_stopped() { trigger.stop(); clearInvocations(detector); events.next(new InstanceRegisteredEvent(instance.getId(), instance.getVersion(), instance.getRegistration())); verify(detector, never()).detectEndpoints(instance.getId()); }
protected Mono<Void> detectEndpoints(InstanceEvent event) { return endpointDetector.detectEndpoints(event.getInstance()); }
EndpointDetectionTrigger extends AbstractEventHandler<InstanceEvent> { protected Mono<Void> detectEndpoints(InstanceEvent event) { return endpointDetector.detectEndpoints(event.getInstance()); } }
EndpointDetectionTrigger extends AbstractEventHandler<InstanceEvent> { protected Mono<Void> detectEndpoints(InstanceEvent event) { return endpointDetector.detectEndpoints(event.getInstance()); } EndpointDetectionTrigger(EndpointDetector endpointDetector, Publisher<InstanceEvent> publisher); }
EndpointDetectionTrigger extends AbstractEventHandler<InstanceEvent> { protected Mono<Void> detectEndpoints(InstanceEvent event) { return endpointDetector.detectEndpoints(event.getInstance()); } EndpointDetectionTrigger(EndpointDetector endpointDetector, Publisher<InstanceEvent> publisher);  }
EndpointDetectionTrigger extends AbstractEventHandler<InstanceEvent> { protected Mono<Void> detectEndpoints(InstanceEvent event) { return endpointDetector.detectEndpoints(event.getInstance()); } EndpointDetectionTrigger(EndpointDetector endpointDetector, Publisher<InstanceEvent> publisher);   }