Class: Pubsub::Redis::DomainEventListener

Inherits:
DomainEventListener
  • Object
show all
Defined in:
lib/pubsub/redis.rb

Instance Method Summary collapse

Constructor Details

#initialize(redis_client, channel) ⇒ DomainEventListener

Returns a new instance of DomainEventListener.



21
22
23
24
# File 'lib/pubsub/redis.rb', line 21

def initialize(redis_client, channel)
  @redis_client = redis_client
  @channel = channel
end

Instance Method Details

#listen(&_block) ⇒ Object



26
27
28
29
30
# File 'lib/pubsub/redis.rb', line 26

def listen(&_block)
  @redis_client.subscribe(@channel) do |message|
    yield message
  end
end