diff --git a/src/rmq/rmqamqp/rmqamqp_channelmap.cpp b/src/rmq/rmqamqp/rmqamqp_channelmap.cpp index 2fab7f1..b2c3305 100644 --- a/src/rmq/rmqamqp/rmqamqp_channelmap.cpp +++ b/src/rmq/rmqamqp/rmqamqp_channelmap.cpp @@ -161,7 +161,8 @@ bool ChannelMap::processReceived(uint16_t channelId, return false; } - Channel::CleanupIndicator cleanupInd = it->second->processReceived(message); + const bsl::shared_ptr channel = it->second; + Channel::CleanupIndicator cleanupInd = channel->processReceived(message); if (cleanupInd == Channel::CLEANUP) { // invalidates iterator