diff --git a/src/main/java/net/krakatoa/proxy/listener/PlayerDisconnectListener.java b/src/main/java/net/krakatoa/proxy/listener/PlayerDisconnectListener.java index 42c308e..9b37a91 100755 --- a/src/main/java/net/krakatoa/proxy/listener/PlayerDisconnectListener.java +++ b/src/main/java/net/krakatoa/proxy/listener/PlayerDisconnectListener.java @@ -37,7 +37,7 @@ public class PlayerDisconnectListener implements Listener { .getPlayersCollection() .find(Filters.eq("uuid", uuid)).first(); - document.subscribe(new Subscriber() { + document.subscribe(new Subscriber<>() { @Override public void onSubscribe(Subscription subscription) { subscription.request(1); diff --git a/src/main/java/net/krakatoa/proxy/listener/PostLoginListener.java b/src/main/java/net/krakatoa/proxy/listener/PostLoginListener.java index 7e4a5f1..44649fe 100755 --- a/src/main/java/net/krakatoa/proxy/listener/PostLoginListener.java +++ b/src/main/java/net/krakatoa/proxy/listener/PostLoginListener.java @@ -32,7 +32,7 @@ public class PostLoginListener implements Listener { .getPlayersCollection() .find(Filters.eq("uuid", uuid)).first(); - document.subscribe(new Subscriber() { + document.subscribe(new Subscriber<>() { @Override public void onSubscribe(Subscription subscription) { subscription.request(1); @@ -40,7 +40,7 @@ public class PostLoginListener implements Listener { @Override public void onNext(Document document) { - ProxySystem.getInstance().getLogger().info(("Inserted: " + document)); + ProxySystem.getInstance().getLogger().info("Inserted: " + document); } @Override