fixes #1565: Allow session to flush commands on an engine error

This commit is contained in:
Charles Stanley
2015-11-30 10:05:25 -05:00
committed by vagrant
parent e56b486735
commit 54799c8c6f
3 changed files with 12 additions and 0 deletions

View File

@@ -428,6 +428,9 @@ void zmq::session_base_t::engine_error (
if (zap_pipe)
zap_pipe->check_read ();
zmq_assert(socket);
socket->flush_commands();
}
void zmq::session_base_t::process_term (int linger_)