class SplitIoClient::Cache::Repositories::Events::RedisRepository

def clear
  @adapter.get_from_queue(namespace_key('.events'), 0).map do |e|
    JSON.parse(e, symbolize_names: true)
  end
rescue StandardError => e
  @config.logger.error("Exception while clearing events cache: #{e}")
  []
end