Update Connection.java

修复 Queue full错误 brainlag#50
ec-web · Dec 29, 2020 · 9eb131b · 9eb131b
1 parent 6fc435f
commit 9eb131b
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/main/java/com/github/brainlag/nsq/Connection.java b/src/main/java/com/github/brainlag/nsq/Connection.java
@@ -121,12 +121,17 @@ public void incoming(final NSQFrame frame) {
                 return;
             }
         }
+
 
         if (frame instanceof ErrorFrame) {
             if (errorCallback != null) {
                 errorCallback.error(NSQException.of((ErrorFrame) frame));
             }
-            responses.add(frame);
+            try {
+                this.responses.offer(frame, 1, TimeUnit.SECONDS);
+            } catch (InterruptedException e) {
+                log.error("Dropping incoming frame error", e);
+            }
             return;
         }