EgtExecutor :
- in Redis piccola correzione nella ricerca dei messaggi.
This commit is contained in:
+2
-2
@@ -1099,7 +1099,7 @@ ExeRedisAsyncDisconnect( int nIdConnection)
|
||||
|
||||
// Elimino i Messaggi dalla mappa
|
||||
for ( auto Iter = vAsyncRedisMessages.begin() ; Iter != vAsyncRedisMessages.end() ; ) {
|
||||
if ( Iter->first.rfind( GetMessageMapKey( nIdConnection, "")) == 0)
|
||||
if ( Iter->first.compare( GetMessageMapKey( nIdConnection, "")) == 0)
|
||||
Iter = vAsyncRedisMessages.erase( Iter) ;
|
||||
else
|
||||
++ Iter ;
|
||||
@@ -1259,7 +1259,7 @@ ExeRedisAsyncUnsubscribe( int nIdConnection, const string& sChannel)
|
||||
|
||||
// Elimino i Messaggi dalla mappa
|
||||
for ( auto Iter = vAsyncRedisMessages.begin() ; Iter != vAsyncRedisMessages.end() ; ) {
|
||||
if ( Iter->first.rfind( GetMessageMapKey( nIdConnection, sChannel)) == 0)
|
||||
if ( Iter->first.compare( GetMessageMapKey( nIdConnection, sChannel)) == 0)
|
||||
Iter = vAsyncRedisMessages.erase( Iter) ;
|
||||
else
|
||||
++ Iter ;
|
||||
|
||||
Reference in New Issue
Block a user