Class: ZQ::Composer::RedisPublish
- Inherits:
-
Object
- Object
- ZQ::Composer::RedisPublish
- Defined in:
- lib/zq/composers/redis.rb
Instance Method Summary collapse
- #compose(raw_data, composite = nil) ⇒ Object
-
#initialize(channel_name, client) ⇒ RedisPublish
constructor
A new instance of RedisPublish.
Constructor Details
#initialize(channel_name, client) ⇒ RedisPublish
Returns a new instance of RedisPublish.
4 5 6 7 |
# File 'lib/zq/composers/redis.rb', line 4 def initialize(channel_name, client) @channel_name = channel_name @client = client end |
Instance Method Details
#compose(raw_data, composite = nil) ⇒ Object
8 9 10 11 12 |
# File 'lib/zq/composers/redis.rb', line 8 def compose(raw_data, composite = nil) composite ||= raw_data @client.publish(@channel_name, composite) composite end |