mirror of
https://github.com/proxiodev/RedisBungee.git
synced 2025-04-20 01:27:07 +00:00
use continue instead of break
This commit is contained in:
parent
72025bc22c
commit
70aacc99c0
@ -335,7 +335,7 @@ public abstract class ProxyDataManager implements Runnable {
|
|||||||
if (!payloadDataManagerUUID.equals(this.dataManagerUUID)) {
|
if (!payloadDataManagerUUID.equals(this.dataManagerUUID)) {
|
||||||
plugin.logWarn("detected other proxy is using same ID! {} this can cause issues, please shutdown this proxy and change the id!", this.proxyId);
|
plugin.logWarn("detected other proxy is using same ID! {} this can cause issues, please shutdown this proxy and change the id!", this.proxyId);
|
||||||
}
|
}
|
||||||
break;
|
continue;
|
||||||
}
|
}
|
||||||
if (unknownPayload instanceof HeartbeatPayload payload) {
|
if (unknownPayload instanceof HeartbeatPayload payload) {
|
||||||
handleHeartBeat(payload);
|
handleHeartBeat(payload);
|
||||||
@ -344,6 +344,8 @@ public abstract class ProxyDataManager implements Runnable {
|
|||||||
} else if (unknownPayload instanceof RunCommandPayload payload) {
|
} else if (unknownPayload instanceof RunCommandPayload payload) {
|
||||||
handleCommand(payload);
|
handleCommand(payload);
|
||||||
} else if (unknownPayload instanceof PubSubPayload payload) {
|
} else if (unknownPayload instanceof PubSubPayload payload) {
|
||||||
|
System.out.println("HANDLED PUBSUB?");
|
||||||
|
|
||||||
handleChannelMessage(payload);
|
handleChannelMessage(payload);
|
||||||
} else {
|
} else {
|
||||||
plugin.logWarn("got unknown data manager payload: {}", unknownPayload.getClassName());
|
plugin.logWarn("got unknown data manager payload: {}", unknownPayload.getClassName());
|
||||||
|
Loading…
Reference in New Issue
Block a user