Audit-service add codes of config

apache · Apr 7, 2024 · d9d70fc · d9d70fc
1 parent f1eb3de
commit d9d70fc
Showing 1 changed file with 2 additions and 8 deletions.
diff --git a/inlong-audit/audit-service/src/main/java/channel/DataQueue.java b/inlong-audit/audit-service/src/main/java/channel/DataQueue.java
@@ -53,14 +53,8 @@ public void push(StatData statDataPo) throws InterruptedException {
      * @param unit
      * @return
      */
-    public StatData pull(long timeout, TimeUnit unit) {
-        StatData message = null;
-        try {
-            message = queue.poll(timeout, unit);
-        } catch (InterruptedException ex) {
-            LOG.error(ex.getMessage());
-        }
-        return message;
+    public StatData pull(long timeout, TimeUnit unit) throws InterruptedException {
+        return queue.poll(timeout, unit);
     }
 
     /**