diff options
| -rw-r--r-- | src/app_thread.cpp | 6 |
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; } |