From bd3a4e1ad76876dee23e9403faf93d4ae25f5c64 Mon Sep 17 00:00:00 2001 From: Luck Date: Sun, 18 Mar 2018 18:58:53 +0000 Subject: [PATCH] Fix Sql messenger table name & bug which meant entries were only received after a 1 min delay --- .../luckperms/common/messaging/sql/AbstractSqlMessenger.java | 2 +- .../me/lucko/luckperms/common/messaging/sql/SqlMessenger.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/common/src/main/java/me/lucko/luckperms/common/messaging/sql/AbstractSqlMessenger.java b/common/src/main/java/me/lucko/luckperms/common/messaging/sql/AbstractSqlMessenger.java index 79f9c1f2..6ad698cb 100644 --- a/common/src/main/java/me/lucko/luckperms/common/messaging/sql/AbstractSqlMessenger.java +++ b/common/src/main/java/me/lucko/luckperms/common/messaging/sql/AbstractSqlMessenger.java @@ -82,7 +82,7 @@ public abstract class AbstractSqlMessenger implements Messenger { public void pollMessages() { try (Connection c = getConnection()) { - try (PreparedStatement ps = c.prepareStatement("SELECT `id`, `msg` FROM " + getTableName() + " WHERE `id` > ? AND (NOW() - `time` > 60)")) { + try (PreparedStatement ps = c.prepareStatement("SELECT `id`, `msg` FROM " + getTableName() + " WHERE `id` > ? AND (NOW() - `time` < 30)")) { ps.setLong(1, this.lastId); try (ResultSet rs = ps.executeQuery()) { while (rs.next()) { diff --git a/common/src/main/java/me/lucko/luckperms/common/messaging/sql/SqlMessenger.java b/common/src/main/java/me/lucko/luckperms/common/messaging/sql/SqlMessenger.java index 892c9171..1327d4e8 100644 --- a/common/src/main/java/me/lucko/luckperms/common/messaging/sql/SqlMessenger.java +++ b/common/src/main/java/me/lucko/luckperms/common/messaging/sql/SqlMessenger.java @@ -85,6 +85,6 @@ public class SqlMessenger extends AbstractSqlMessenger { @Override protected String getTableName() { - return this.sqlDao.getPrefix().apply("{prefix}_messages"); + return this.sqlDao.getPrefix().apply("{prefix}messages"); } }