diff --git a/lib/splitclient-rb/cache/senders/impressions_adapter/redis_sender.rb b/lib/splitclient-rb/cache/senders/impressions_adapter/redis_sender.rb
index b714c1b1..e7cad03f 100644
--- a/lib/splitclient-rb/cache/senders/impressions_adapter/redis_sender.rb
+++ b/lib/splitclient-rb/cache/senders/impressions_adapter/redis_sender.rb
@@ -14,12 +14,13 @@ def initialize(config)
         def record_uniques_key(uniques)
           return if uniques.nil? || uniques == {}
 
-          size = 0
-          uniques.each do |key, value|
-            size = @adapter.add_to_queue(unique_keys_key, { f: key, ks: value.to_a }.to_json)
+          size = @adapter.redis.pipelined do |pipeline|
+            uniques.each do |key, value|
+              pipeline.rpush(unique_keys_key, { f: key, ks: value.to_a }.to_json)
+            end
           end
 
-          @adapter.expire(unique_keys_key, EXPIRE_SECONDS) if uniques.length == size
+          @adapter.expire(unique_keys_key, EXPIRE_SECONDS) if uniques.length == size.last
         rescue StandardError => e
           @config.log_found_exception(__method__.to_s, e)
         end