Upstream/LuckPerms
1
0
Fork 0
mirror of https://github.com/LuckPerms/LuckPerms.git synced 2024-11-24 11:38:40 +01:00
Code Issues Projects Releases Wiki Activity

Update messenger log prefixes

Browse Source
This commit is contained in:
Luck 2018-08-31 20:22:31 +01:00
parent 502d57e744
commit ec9060ba80
No known key found for this signature in database
GPG Key ID: EFA9B3EC5FD90F8B
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
common/src/main/java/me/lucko/luckperms/common/messaging/LuckPermsMessagingService.java
View File

@ -114,7 +114,7 @@ public class LuckPermsMessagingService implements InternalMessagingService, Inco
public void pushUpdate() { public void pushUpdate() {
this.plugin.getBootstrap().getScheduler().executeAsync(() -> { this.plugin.getBootstrap().getScheduler().executeAsync(() -> {
UUID requestId = generatePingId(); UUID requestId = generatePingId();
this.plugin.getLogger().info("[" + getName() + " Messaging] Sending ping with id: " + requestId); this.plugin.getLogger().info("[Messaging] Sending ping with id: " + requestId);
this.messenger.sendOutgoingMessage(new UpdateMessageImpl(requestId)); this.messenger.sendOutgoingMessage(new UpdateMessageImpl(requestId));
}); });
} }
@ -123,7 +123,7 @@ public class LuckPermsMessagingService implements InternalMessagingService, Inco
public void pushUserUpdate(User user) { public void pushUserUpdate(User user) {
this.plugin.getBootstrap().getScheduler().executeAsync(() -> { this.plugin.getBootstrap().getScheduler().executeAsync(() -> {
UUID requestId = generatePingId(); UUID requestId = generatePingId();
this.plugin.getLogger().info("[" + getName() + " Messaging] Sending user ping for '" + user.getFriendlyName() + "' with id: " + requestId); this.plugin.getLogger().info("[Messaging] Sending user ping for '" + user.getFriendlyName() + "' with id: " + requestId);
this.messenger.sendOutgoingMessage(new UserUpdateMessageImpl(requestId, user.getUuid())); this.messenger.sendOutgoingMessage(new UserUpdateMessageImpl(requestId, user.getUuid()));
}); });
} }
@ -137,7 +137,7 @@ public class LuckPermsMessagingService implements InternalMessagingService, Inco
return; return;
} }
this.plugin.getLogger().info("[" + getName() + " Messaging] Sending log with id: " + requestId); this.plugin.getLogger().info("[Messaging] Sending log with id: " + requestId);
this.messenger.sendOutgoingMessage(new LogMessageImpl(requestId, logEntry)); this.messenger.sendOutgoingMessage(new LogMessageImpl(requestId, logEntry));
}); });
} }
@ -233,7 +233,7 @@ public class LuckPermsMessagingService implements InternalMessagingService, Inco
if (message instanceof UpdateMessage) { if (message instanceof UpdateMessage) {
UpdateMessage msg = (UpdateMessage) message; UpdateMessage msg = (UpdateMessage) message;
this.plugin.getLogger().info("[" + getName() + " Messaging] Received update ping with id: " + msg.getId()); this.plugin.getLogger().info("[Messaging] Received update ping with id: " + msg.getId());
if (this.plugin.getEventFactory().handleNetworkPreSync(false, msg.getId())) { if (this.plugin.getEventFactory().handleNetworkPreSync(false, msg.getId())) {
return; return;
@ -248,7 +248,7 @@ public class LuckPermsMessagingService implements InternalMessagingService, Inco
return; return;
} }
this.plugin.getLogger().info("[" + getName() + " Messaging] Received user update ping for '" + user.getFriendlyName() + "' with id: " + msg.getId()); this.plugin.getLogger().info("[Messaging] Received user update ping for '" + user.getFriendlyName() + "' with id: " + msg.getId());
if (this.plugin.getEventFactory().handleNetworkPreSync(false, msg.getId())) { if (this.plugin.getEventFactory().handleNetworkPreSync(false, msg.getId())) {
return; return;