Class: Kazoo::StaticSubscription

Inherits:
Subscription show all
Defined in:
lib/kazoo/subscription.rb

Overview

StaticSubscription describes a subscription based on a static list of topic names.

Instance Attribute Summary collapse

Attributes inherited from Subscription

#timestamp, #version

Instance Method Summary collapse

Methods inherited from Subscription

build, #eql?, everything, from_json, #hash, #inspect, #partitions, #to_json, topic_name, #topics

Constructor Details

#initialize(topic_names, **kwargs) ⇒ StaticSubscription

Instantiates a static subscription instance. The topic_names argument must be an array of strings.



157
158
159
160
 
# File 'lib/kazoo/subscription.rb', line 157

def initialize(topic_names, **kwargs)
  super(**kwargs)
  @topic_names = topic_names
end

Instance Attribute Details

#topic_names ⇒ Object (readonly)

Returns the value of attribute topic_names.



153
154
155
 
# File 'lib/kazoo/subscription.rb', line 153

def topic_names
  @topic_names
end

Instance Method Details

#has_topic?(topic) ⇒ Boolean

Returns:

  • (Boolean) 


162
163
164
 
# File 'lib/kazoo/subscription.rb', line 162

def has_topic?(topic)
  topic_names.include?(topic.name)
end