lib/redis/stream/client.rb in redis-stream-0.4.3 vs lib/redis/stream/client.rb in redis-stream-0.4.4

@@ -217,11 +217,11 @@
           OpenTracing.inject(tracer_span.context, OpenTracing::FORMAT_TEXT_MAP, tracer_data)
         end
         payload = nil
 
         unless @cache.nil?
-          if options["cache_key"].nil?
+          if options.include?("cache_key")
             cache_key = @cache.build_key(data)
             if @cache.include?(cache_key)
               if data && data.include?('from_cache') && data['from_cache'].eql?(0)
                 @cache.delete(cache_key)
                 @logger.info("#{@consumer_id} - invalidating cache with key #{cache_key}")
@@ -238,9 +238,10 @@
                 @logger.info("#{@consumer_id} - fetching from cache with key #{cache_key}")
               end
 
             end
           else
+            @logger.info("#{@consumer_id} - fetching from cache with key #{cache_key}")
             @cache[options["cache_key"]] = data
           end
 
         end
         if payload.nil?
\ No newline at end of file