From a0a10c02be17552c6fb670da91d2bb6781e74240 Mon Sep 17 00:00:00 2001 From: Alex Nekipelov Date: Wed, 18 Oct 2017 21:39:07 +0300 Subject: [PATCH] update amalgamated sources --- amalgamated/redisclient.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/amalgamated/redisclient.cpp b/amalgamated/redisclient.cpp index 6dfbf81..13a2859 100644 --- a/amalgamated/redisclient.cpp +++ b/amalgamated/redisclient.cpp @@ -302,13 +302,13 @@ void RedisClientImpl::doProcessMessage(RedisValue v) const RedisValue &command = result[0]; const RedisValue &queueName = result[(resultSize == 3)?1:2]; const RedisValue &value = result[(resultSize == 3)?2:3]; - const RedisValue &pattern = (resultSize == 4) ? result[1] : ""; + const RedisValue &pattern = (resultSize == 4) ? result[1] : queueName; std::string cmd = command.toString(); if( cmd == "message" || cmd == "pmessage" ) { - SingleShotHandlersMap::iterator it = singleShotMsgHandlers.find(queueName.toString()); + SingleShotHandlersMap::iterator it = singleShotMsgHandlers.find(pattern.toString()); if( it != singleShotMsgHandlers.end() ) { strand.post(std::bind(it->second, value.toByteArray())); @@ -316,7 +316,7 @@ void RedisClientImpl::doProcessMessage(RedisValue v) } std::pair pair = - msgHandlers.equal_range(queueName.toString()); + msgHandlers.equal_range(pattern.toString()); for(MsgHandlersMap::iterator handlerIt = pair.first; handlerIt != pair.second; ++handlerIt) {