minecraft/LuckPerms
1
0
Fork 0
mirror of https://github.com/lucko/LuckPerms.git synced 2025-09-03 11:22:33 +02:00
Code Issues Releases Wiki Activity

Reattempt RabbitMQ connection on first attempt

Browse Source
This commit is contained in:
Luck
2023-05-01 10:00:05 +01:00
parent cfe0d806a1
commit 9640271260
1 changed files with 13 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
common/src/main/java/me/lucko/luckperms/common/messaging/rabbitmq/RabbitMQMessenger.java
View File

@@ -156,10 +156,21 @@ public class RabbitMQMessenger implements Messenger {
this.plugin.getLogger().info("RabbitMQ pubsub connection re-established"); this.plugin.getLogger().info("RabbitMQ pubsub connection re-established");
} }
return true; return true;
} catch (Exception ignored) { } catch (Exception e) {
if (firstStartup) {
this.plugin.getLogger().warn("Unable to connect to RabbitMQ, waiting for 5 seconds then retrying...", e);
try {
Thread.sleep(5000);
} catch (InterruptedException ex) {
Thread.currentThread().interrupt();
}
return checkAndReopenConnection(false);
} else {
this.plugin.getLogger().severe("Unable to connect to RabbitMQ", e);
return false; return false;
} }
} }
}
private class Subscription implements DeliverCallback { private class Subscription implements DeliverCallback {
@Override @Override