Contents

# -*- encoding: utf-8 -*-

# A round-robin client pool. Clients are processed sequentially, and once
# all clients have been processed, the pool cycles back to the beginning.
class OnStomp::Failover::Pools::RoundRobin < OnStomp::Failover::Pools::Base
  def initialize uris, options = {}
    super
    @index = -1
  end

  # Returns the next sequential client in the pool
  # @return [OnStomp::Client]
  def next_client
    @index = (@index + 1) % clients.size
    clients[@index]
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
onstomp-1.0.12	lib/onstomp/failover/pools/round_robin.rb
onstomp-1.0.11	lib/onstomp/failover/pools/round_robin.rb
onstomp-1.0.10	lib/onstomp/failover/pools/round_robin.rb
onstomp-1.0.9	lib/onstomp/failover/pools/round_robin.rb