ISSUE-694 BeforeDestroy realization

eutkin · eutkin · commit a69569b6f08e · 2020-01-10T19:21:51.000+03:00
diff --git a/services/src/test/java/io/scalecube/services/sut/AnnotationServiceImpl.java b/services/src/test/java/io/scalecube/services/sut/AnnotationServiceImpl.java
@@ -12,7 +12,7 @@ public class AnnotationServiceImpl implements AnnotationService {
   private ReplayProcessor<ServiceDiscoveryEvent> serviceDiscoveryEvents;
 
   @AfterConstruct
-  void init(Microservices microservices) {
+  private void init(Microservices microservices) {
     this.serviceDiscoveryEvents = ReplayProcessor.create();
     microservices.discovery().listenDiscovery().subscribe(serviceDiscoveryEvents);
   }
@@ -23,7 +23,7 @@ public Flux<ServiceDiscoveryEvent.Type> serviceDiscoveryEventTypes() {
   }
 
   @BeforeDestroy
-  void destroy(Microservices microservices) {
+  private void destroy(Microservices microservices) {
     this.serviceDiscoveryEvents = ReplayProcessor.create();
     microservices.discovery().listenDiscovery().subscribe(serviceDiscoveryEvents);
   }

Original file line number	Diff line number	Diff line change
`@@ -12,7 +12,7 @@ public class AnnotationServiceImpl implements AnnotationService {`
`12`	`12`	`private ReplayProcessor<ServiceDiscoveryEvent> serviceDiscoveryEvents;`
`13`	`13`
`14`	`14`	`@AfterConstruct`
`15`		`- void init(Microservices microservices) {`
	`15`	`+ private void init(Microservices microservices) {`
`16`	`16`	`this.serviceDiscoveryEvents = ReplayProcessor.create();`
`17`	`17`	`microservices.discovery().listenDiscovery().subscribe(serviceDiscoveryEvents);`
`18`	`18`	`}`
`@@ -23,7 +23,7 @@ public Flux<ServiceDiscoveryEvent.Type> serviceDiscoveryEventTypes() {`
`23`	`23`	`}`
`24`	`24`
`25`	`25`	`@BeforeDestroy`
`26`		`- void destroy(Microservices microservices) {`
	`26`	`+ private void destroy(Microservices microservices) {`
`27`	`27`	`this.serviceDiscoveryEvents = ReplayProcessor.create();`
`28`	`28`	`microservices.discovery().listenDiscovery().subscribe(serviceDiscoveryEvents);`
`29`	`29`	`}`