diff --git a/src/main/java/DataLock.java b/src/main/java/DataLock.java index 1f239f8..2f6fbed 100644 --- a/src/main/java/DataLock.java +++ b/src/main/java/DataLock.java @@ -5,7 +5,7 @@ import org.bukkit.scheduler.BukkitRunnable; import java.util.HashSet; import java.util.UUID; -class DataLock implements DataLockInterface { +class DataLock { private static DataLock instance = null; @@ -39,26 +39,22 @@ class DataLock implements DataLockInterface { return activeRequests.removeIdempotencyData(requestType, idempotencyData); } - @Override public synchronized void registerChannel(String channel) { activeChannels.add(channel); plugin.getServer().getMessenger().registerOutgoingPluginChannel(plugin, channel); plugin.getServer().getMessenger().registerIncomingPluginChannel(plugin, channel, pluginMessageListener); } - @Override public synchronized boolean isActiveChannel(String channel) { return activeChannels.contains(channel); } - @Override public void tryLock(String channel, String data) { IdempotencyData idempotencyData = new IdempotencyData(channel, data, UUID.randomUUID()); activeRequests.putIdempotencyData(RequestType.TRY_LOCK, idempotencyData); sendPluginMessage(RequestType.TRY_LOCK, idempotencyData); } - @Override public void tryUnlock(String channel, String data) { IdempotencyData idempotencyData = new IdempotencyData(channel, data, UUID.randomUUID()); activeRequests.putIdempotencyData(RequestType.TRY_UNLOCK, idempotencyData); diff --git a/src/main/java/DataLockInterface.java b/src/main/java/DataLockInterface.java deleted file mode 100644 index 46473cf..0000000 --- a/src/main/java/DataLockInterface.java +++ /dev/null @@ -1,11 +0,0 @@ -public interface DataLockInterface { - - void tryLock(String channel, String data); - - void tryUnlock(String channel, String data); - - void registerChannel(String channel); - - boolean isActiveChannel(String channel); - -}