fix

apache · Nov 26, 2024 · 8b23d2b · 8b23d2b
1 parent 35b6b4c
commit 8b23d2b
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/...dk/dirty-data-sdk/src/main/java/org/apache/inlong/sdk/dirtydata/InlongSdkDirtySender.java b/...dk/dirty-data-sdk/src/main/java/org/apache/inlong/sdk/dirtydata/InlongSdkDirtySender.java
@@ -77,10 +77,12 @@ public void sendDirtyMessageSync(DirtyMessageWrapper messageWrapper) throws Inte
         dirtyDataQueue.put(messageWrapper);
     }
 
-    public void sendDirtyMessageAsync(DirtyMessageWrapper messageWrapper) throws InterruptedException {
-        if(!dirtyDataQueue.offer(messageWrapper)) {
-            log.warn("the dirty data queue is full, you can increase the size of queue by configure maxCallbackSize");
+    public boolean sendDirtyMessageAsync(DirtyMessageWrapper messageWrapper) {
+        boolean result = dirtyDataQueue.offer(messageWrapper);
+        if (!result) {
+            log.warn("send dirty message async queue is full, you can increase maxCallbackSize");
         }
+        return result;
     }
 
     private void doSendDirtyMessage() {