debug: mongodb document subscriber
parent
f93e0bc684
commit
733e580c90
|
@ -32,10 +32,12 @@ public class PostLoginListener implements Listener {
|
||||||
.getPlayersCollection()
|
.getPlayersCollection()
|
||||||
.find(Filters.eq("uuid", uuid)).first();
|
.find(Filters.eq("uuid", uuid)).first();
|
||||||
|
|
||||||
|
ProxySystem.getInstance().getLogger().info("debug1");
|
||||||
document.subscribe(new Subscriber<>() {
|
document.subscribe(new Subscriber<>() {
|
||||||
@Override
|
@Override
|
||||||
public void onSubscribe(Subscription subscription) {
|
public void onSubscribe(Subscription subscription) {
|
||||||
subscription.request(1);
|
subscription.request(1);
|
||||||
|
ProxySystem.getInstance().getLogger().info("Subscripe");
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@ -53,6 +55,7 @@ public class PostLoginListener implements Listener {
|
||||||
ProxySystem.getInstance().getLogger().info("Completed");
|
ProxySystem.getInstance().getLogger().info("Completed");
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
ProxySystem.getInstance().getLogger().info("debug2");
|
||||||
/*
|
/*
|
||||||
if (document == null) { // new player - create entries in databases
|
if (document == null) { // new player - create entries in databases
|
||||||
System.out.println("create player in db");
|
System.out.println("create player in db");
|
||||||
|
|
Loading…
Reference in New Issue