Altitude/DataLockLib
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Removed interface

Browse Source
This commit is contained in:
Teriuihi 2022-10-06 17:36:54 +02:00
parent f5d1d20c10
commit 63eb2e1c77
2 changed files with 1 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/DataLock.java
View File

@ -5,7 +5,7 @@ import org.bukkit.scheduler.BukkitRunnable;
import java.util.HashSet; import java.util.HashSet;
import java.util.UUID; import java.util.UUID;
class DataLock implements DataLockInterface { class DataLock {
private static DataLock instance = null; private static DataLock instance = null;
@ -39,26 +39,22 @@ class DataLock implements DataLockInterface {
return activeRequests.removeIdempotencyData(requestType, idempotencyData); return activeRequests.removeIdempotencyData(requestType, idempotencyData);
} }
@Override
public synchronized void registerChannel(String channel) { public synchronized void registerChannel(String channel) {
activeChannels.add(channel); activeChannels.add(channel);
plugin.getServer().getMessenger().registerOutgoingPluginChannel(plugin, channel); plugin.getServer().getMessenger().registerOutgoingPluginChannel(plugin, channel);
plugin.getServer().getMessenger().registerIncomingPluginChannel(plugin, channel, pluginMessageListener); plugin.getServer().getMessenger().registerIncomingPluginChannel(plugin, channel, pluginMessageListener);
} }
@Override
public synchronized boolean isActiveChannel(String channel) { public synchronized boolean isActiveChannel(String channel) {
return activeChannels.contains(channel); return activeChannels.contains(channel);
} }
@Override
public void tryLock(String channel, String data) { public void tryLock(String channel, String data) {
IdempotencyData idempotencyData = new IdempotencyData(channel, data, UUID.randomUUID()); IdempotencyData idempotencyData = new IdempotencyData(channel, data, UUID.randomUUID());
activeRequests.putIdempotencyData(RequestType.TRY_LOCK, idempotencyData); activeRequests.putIdempotencyData(RequestType.TRY_LOCK, idempotencyData);
sendPluginMessage(RequestType.TRY_LOCK, idempotencyData); sendPluginMessage(RequestType.TRY_LOCK, idempotencyData);
} }
@Override
public void tryUnlock(String channel, String data) { public void tryUnlock(String channel, String data) {
IdempotencyData idempotencyData = new IdempotencyData(channel, data, UUID.randomUUID()); IdempotencyData idempotencyData = new IdempotencyData(channel, data, UUID.randomUUID());
activeRequests.putIdempotencyData(RequestType.TRY_UNLOCK, idempotencyData); activeRequests.putIdempotencyData(RequestType.TRY_UNLOCK, idempotencyData);

11
src/main/java/DataLockInterface.java
View File

@ -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);
}