ambiser
/
openvidu
mirror of https://github.com/OpenVidu/openvidu.git
8
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

openvidu-test-browsers: CustomWebhook councurrent bug fix

pull/431/head
pabloFuente 2020-04-11 14:34:56 +02:00
parent 675de73351
commit 963a9d6b40
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
openvidu-test-browsers/src/main/java/io/openvidu/test/browsers/utils/CustomWebhook.java
View File

@ -17,9 +17,9 @@
package io.openvidu.test.browsers.utils; package io.openvidu.test.browsers.utils;
import java.util.Map;
import java.util.concurrent.BlockingQueue; import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.CountDownLatch; import java.util.concurrent.CountDownLatch;
import java.util.concurrent.LinkedBlockingDeque; import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@ -45,7 +45,7 @@ public class CustomWebhook {
private static ConfigurableApplicationContext context; private static ConfigurableApplicationContext context;
public static CountDownLatch initLatch; public static CountDownLatch initLatch;
private static Map<String, BlockingQueue<JsonObject>> events = new ConcurrentHashMap<>(); static ConcurrentMap<String, BlockingQueue<JsonObject>> events = new ConcurrentHashMap<>();
public static void main(String[] args, CountDownLatch initLatch) { public static void main(String[] args, CountDownLatch initLatch) {
CustomWebhook.initLatch = initLatch; CustomWebhook.initLatch = initLatch;
@ -77,11 +77,13 @@ public class CustomWebhook {
public void webhook(@RequestBody String eventString) { public void webhook(@RequestBody String eventString) {
JsonObject event = JsonParser.parseString(eventString).getAsJsonObject(); JsonObject event = JsonParser.parseString(eventString).getAsJsonObject();
final String eventName = event.get("event").getAsString(); final String eventName = event.get("event").getAsString();
System.out.println("Webhook event: " + event.toString()); final BlockingQueue<JsonObject> queue = new LinkedBlockingDeque<>();
if (events.get(eventName) == null) { if (!CustomWebhook.events.computeIfAbsent(eventName, e -> {
events.put(eventName, new LinkedBlockingDeque<>()); queue.add(event);
return queue;
}).equals(queue)) {
CustomWebhook.events.get(eventName).add(event);
} }
CustomWebhook.events.get(eventName).add(event);
} }
} }