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

Adds channel callbacks checking

This commit is contained in:
LAD Martin 2019-11-05 13:39:45 +00:00
parent 5a648fe2d8
commit 022bd87ac1
2 changed files with 5 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

@ -218,7 +218,7 @@ public:
_readyCallback = callback; _readyCallback = callback;
// direct call if channel is already ready // direct call if channel is already ready
if (_state == state_ready) callback(); if (_state == state_ready && callback) callback();
} }
/** /**

3
src/channelimpl.cpp
View File

@ -74,6 +74,9 @@ void ChannelImpl::onError(const ErrorCallback &callback)
// if the channel is usable, all is ok // if the channel is usable, all is ok
if (usable()) return; if (usable()) return;
// validity check
if (!callback) return;
// is the channel closing down? // is the channel closing down?
if (_state == state_closing) return callback("Channel is closing down"); if (_state == state_closing) return callback("Channel is closing down");