-
Notifications
You must be signed in to change notification settings - Fork 5
/
VerticleC.java
43 lines (32 loc) · 1.17 KB
/
VerticleC.java
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
36
37
38
39
40
41
42
43
package org.genericsystem.watch.beta;
import org.genericsystem.kernel.Engine;
import io.vertx.core.AbstractVerticle;
import io.vertx.core.eventbus.MessageConsumer;
public class VerticleC extends AbstractVerticle{
public static void main(String[] args) {
App_Flex.deployVerticle(new VerticleC());
}
@Override
public void start() throws Exception {
Engine engineB = new Engine("/home/middleware/ymoumna/VertC/",Task.class,State.class);
System.out.println("Verticle C");
MessageConsumer<String> consumer = vertx.eventBus().consumer(App_Flex.STEP2);
consumer.handler(message-> vertx.executeBlocking(future ->{
System.out.println("Verticle C : handling event");
try {
Thread.sleep(Long.parseLong(message.body()));
} catch (NumberFormatException | InterruptedException e) {
e.printStackTrace();
}
System.out.println("Verticle C : handled event");
System.out.println("###############################################################################################");
System.gc();
System.runFinalization();
future.complete();
}
, res -> {
if (res.failed())
throw new IllegalStateException(res.cause());
}));
}
}