summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/app_thread.cpp6
1 files changed, 4 insertions, 2 deletions
diff --git a/src/app_thread.cpp b/src/app_thread.cpp
index 19f997b..fbf034c 100644
--- a/src/app_thread.cpp
+++ b/src/app_thread.cpp
@@ -123,9 +123,11 @@ bool zmq::app_thread_t::process_commands (bool block_, bool throttle_)
received = signaler.recv (&cmd, false);
}
- // Process the command, if any.
- if (received)
+ // Process all the commands available at the moment.
+ while (received) {
cmd.destination->process_command (cmd);
+ received = signaler.recv (&cmd, false);
+ }
return !terminated;
}