@@ -145,7 +145,7 @@ public Event applySetListPack(RedisInputStream in, int version, ContextKeyValueP
145145 try {
146146 BaseRdbParser parser = new BaseRdbParser (in );
147147 byte [] key = parser .rdbLoadEncodedStringObject ().first ();
148- boolean contains = filter .contains (context .getDb ().getDbNumber (), RDB_TYPE_SET_LISTPACK , Strings .toString (key ));
148+ boolean contains = filter .contains (context .getDb ().getDbNumber (), RDB_TYPE_SET_LISTPACK , Strings .toString (key ), context . getExpiredType () != ExpiredType . NONE );
149149 if (contains ) {
150150 if (listener != null ) listener .setGuard (DRAIN );
151151 return doApplySetListPack (in , version , key , RDB_TYPE_SET_LISTPACK , context );
@@ -468,7 +468,7 @@ public Event applyStreamListPacks3(RedisInputStream in, int version, ContextKeyV
468468 try {
469469 BaseRdbParser parser = new BaseRdbParser (in );
470470 byte [] key = parser .rdbLoadEncodedStringObject ().first ();
471- boolean contains = filter .contains (context .getDb ().getDbNumber (), RDB_TYPE_STREAM_LISTPACKS_3 , Strings .toString (key ));
471+ boolean contains = filter .contains (context .getDb ().getDbNumber (), RDB_TYPE_STREAM_LISTPACKS_3 , Strings .toString (key ), context . getExpiredType () != ExpiredType . NONE );
472472 if (contains ) {
473473 if (listener != null ) listener .setGuard (DRAIN );
474474 return doApplyStreamListPacks3 (in , version , key , RDB_TYPE_STREAM_LISTPACKS_3 , context );
0 commit comments