Do not proceeed next frame at send failure of previous frame

miniway · Nov 9, 2015 · 9fc9b9e · 9fc9b9e
1 parent ec41b08
commit 9fc9b9e
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/main/java/org/zeromq/ZMsg.java b/src/main/java/org/zeromq/ZMsg.java
@@ -208,6 +208,9 @@ public boolean send(Socket socket, boolean destroy)
         while (i.hasNext()) {
             ZFrame f = i.next();
             ret = f.sendAndKeep(socket, (i.hasNext()) ? ZFrame.MORE : 0);
+            if (!ret) {
+                break;
+            }
         }
         if (destroy) {
             destroy();