blob: d4cc83a35c18a187cf0236e30f8855649883d7d4 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
|
package moe.yuuta.dn42peering.whois;
import io.vertx.core.AbstractVerticle;
import io.vertx.core.Promise;
import io.vertx.core.eventbus.MessageConsumer;
import io.vertx.core.impl.logging.Logger;
import io.vertx.core.impl.logging.LoggerFactory;
import io.vertx.core.json.JsonObject;
import io.vertx.serviceproxy.ServiceBinder;
public class WhoisVerticle extends AbstractVerticle {
private final Logger logger = LoggerFactory.getLogger(getClass().getSimpleName());
private MessageConsumer<JsonObject> consumer;
@Override
public void start(Promise<Void> startPromise) throws Exception {
consumer = new ServiceBinder(vertx)
.setAddress(IWhoisService.ADDRESS)
.register(IWhoisService.class, IWhoisService.create(vertx));
consumer.completionHandler(ar -> {
if(ar.succeeded()) {
startPromise.complete();
} else {
startPromise.fail(ar.cause());
}
});
}
@Override
public void stop(Promise<Void> stopPromise) throws Exception {
consumer.unregister(stopPromise);
}
}
|