Contents

module ResqueBus
  class SubscriptionList
    def self.from_redis(redis_hash)
      out = SubscriptionList.new
      
      redis_hash.each do |key, value|
        sub = Subscription.from_redis(value)
        out.add(sub) if sub
      end
      out
    end
    
    def to_redis
      out = {}
      @subscriptions.values.each do |sub|
        out[sub.key] = sub.to_redis
      end
      out
    end
    
    def initialize
      @subscriptions = {}
    end
    
    def add(sub)
      @subscriptions[sub.key] = sub
    end
    
    def size
      @subscriptions.size
    end
    
    def key(key)
      @subscriptions[key.to_s]
    end
    
    def all
      @subscriptions.values
    end
    
    def matches(attributes)
      out = []
      all.each do |sub|
        out << sub if sub.matches?(attributes)
      end
      out
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
resque-bus-0.2.4	lib/resque_bus/subscription_list.rb
resque-bus-0.2.3	lib/resque_bus/subscription_list.rb