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

Call the events after creating them

Browse Source
This commit is contained in:
Teriuihi 2022-11-11 02:13:51 +01:00
parent 1aa81ec3af
commit bf8890f3e9
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
plugin/src/main/java/com/alttd/datalock/PluginMessageListener.java
View File

@ -35,31 +35,31 @@ class PluginMessageListener implements org.bukkit.plugin.messaging.PluginMessage
if (!alreadyReceived.putIdempotencyData(RequestType.TRY_LOCK, idempotencyData)) if (!alreadyReceived.putIdempotencyData(RequestType.TRY_LOCK, idempotencyData))
return; return;
DataLock.getInstance().removeActiveRequest(RequestType.TRY_LOCK, idempotencyData); DataLock.getInstance().removeActiveRequest(RequestType.TRY_LOCK, idempotencyData);
new LockResponseEvent(true, channel, ResponseType.TRY_LOCK_RESULT, data, result); new LockResponseEvent(true, channel, ResponseType.TRY_LOCK_RESULT, data, result).callEvent();
} }
case "queue-lock-failed" -> { case "queue-lock-failed" -> {
if (!alreadyReceived.putIdempotencyData(RequestType.TRY_LOCK, idempotencyData)) if (!alreadyReceived.putIdempotencyData(RequestType.TRY_LOCK, idempotencyData))
return; return;
DataLock.getInstance().removeActiveRequest(RequestType.TRY_LOCK, idempotencyData); DataLock.getInstance().removeActiveRequest(RequestType.TRY_LOCK, idempotencyData);
new LockResponseEvent(true, channel, ResponseType.QUEUE_LOCK_FAILED, data, result); new LockResponseEvent(true, channel, ResponseType.QUEUE_LOCK_FAILED, data, result).callEvent();
} }
case "try-unlock-result" -> { case "try-unlock-result" -> {
if (!alreadyReceived.putIdempotencyData(RequestType.TRY_UNLOCK, idempotencyData)) if (!alreadyReceived.putIdempotencyData(RequestType.TRY_UNLOCK, idempotencyData))
return; return;
DataLock.getInstance().removeActiveRequest(RequestType.TRY_UNLOCK, idempotencyData); DataLock.getInstance().removeActiveRequest(RequestType.TRY_UNLOCK, idempotencyData);
new LockResponseEvent(true, channel, ResponseType.TRY_UNLOCK_RESULT, data, result); new LockResponseEvent(true, channel, ResponseType.TRY_UNLOCK_RESULT, data, result).callEvent();
} }
case "locked-queue-lock" -> { case "locked-queue-lock" -> {
if (!alreadyReceived.putIdempotencyData(RequestType.TRY_LOCK, idempotencyData)) if (!alreadyReceived.putIdempotencyData(RequestType.TRY_LOCK, idempotencyData))
return; return;
DataLock.getInstance().removeActiveRequest(RequestType.TRY_LOCK, idempotencyData); DataLock.getInstance().removeActiveRequest(RequestType.TRY_LOCK, idempotencyData);
new LockResponseEvent(true, channel, ResponseType.LOCKED_QUEUE_LOCK, data, result); new LockResponseEvent(true, channel, ResponseType.LOCKED_QUEUE_LOCK, data, result).callEvent();
} }
case "check-lock-result" -> { case "check-lock-result" -> {
if (!alreadyReceived.putIdempotencyData(RequestType.CHECK_LOCK, idempotencyData)) if (!alreadyReceived.putIdempotencyData(RequestType.CHECK_LOCK, idempotencyData))
return; return;
DataLock.getInstance().removeActiveRequest(RequestType.CHECK_LOCK, idempotencyData); DataLock.getInstance().removeActiveRequest(RequestType.CHECK_LOCK, idempotencyData);
new LockResponseEvent(true, channel, ResponseType.CHECK_LOCK_RESULT, data, result); new LockResponseEvent(true, channel, ResponseType.CHECK_LOCK_RESULT, data, result).callEvent();
} }
} }
} }