added loop to the listen method

[aleksei-okatiev]

The problem:

The RedisStream::Subscriber.listen method is called in a loop for all our services which leads to creating consumer groups for every iteration in a loop. This leads to a massive overhead to the redis instance:

The solution:

Move loop inside listen method and remove all loops from all our services.
Before:

loop do
  RedisStream::Subscriber.listen(streams: subscribed_to_streams) do |stream, message_id, message_name, payload|
    ....
  end
end

After:

RedisStream::Subscriber.listen(streams: subscribed_to_streams) do |stream, message_id, message_name, payload|
  ....
end