Class: Pollen::Subscriber

Inherits:
Object
  • Object
show all
Defined in:
lib/pollen/subscriber.rb

Instance Method Summary collapse

Constructor Details

#initialize(server) ⇒ Subscriber

Returns a new instance of Subscriber.



7
8
9
# File 'lib/pollen/subscriber.rb', line 7

def initialize(server)
  @server = server
end

Instance Method Details

#start!Object



11
12
13
14
15
16
17
18
# File 'lib/pollen/subscriber.rb', line 11

def start!
  if redis.nil?
    raise Errors::InvalidConfiguration,
          'Redis not set, please assign a Redis client in server configuration'
  end

  Thread.new { subscribe! }
end