jessequ
/
AMQP-CPP
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Connection::fail() will now also call the channel::onError method

This commit is contained in:
Emiel Bruijntjes 2018-11-21 13:56:44 +01:00
parent 549fec5cb1
commit 8eed709988
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
include/amqpcpp/channelimpl.h
View File

@ -623,7 +623,7 @@ public:
// all later deferred objects should report an error, because it // all later deferred objects should report an error, because it
// was not possible to complete the instruction as the channel is // was not possible to complete the instruction as the channel is
// now closed // now closed (but the channel onError does not have to run)
reportError("Channel has been closed", false); reportError("Channel has been closed", false);
// done // done

2
src/connectionimpl.cpp
View File

@ -192,7 +192,7 @@ bool ConnectionImpl::fail(const Monitor &monitor, const char *message)
while (!_channels.empty()) while (!_channels.empty())
{ {
// report the errors // report the errors
_channels.begin()->second->reportError(message, false); _channels.begin()->second->reportError(message);
// leap out if no longer valid // leap out if no longer valid
if (!monitor.valid()) return false; if (!monitor.valid()) return false;