Class: ServicesManager::RabbitServiceClient

Inherits:
Object
  • Object
show all
Defined in:
lib/bunny-pub-sub/services_manager.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(name) ⇒ RabbitServiceClient

Returns a new instance of RabbitServiceClient.



125
126
127
 
# File 'lib/bunny-pub-sub/services_manager.rb', line 125

def initialize(name)
  @name = name
end

Instance Attribute Details

#name ⇒ Object (readonly)

Returns the value of attribute name.



123
124
125
 
# File 'lib/bunny-pub-sub/services_manager.rb', line 123

def name
  @name
end

#publisher ⇒ Object (readonly)

Returns the value of attribute publisher.



122
123
124
 
# File 'lib/bunny-pub-sub/services_manager.rb', line 122

def publisher
  @publisher
end

#subscriber ⇒ Object (readonly)

Returns the value of attribute subscriber.



121
122
123
 
# File 'lib/bunny-pub-sub/services_manager.rb', line 121

def subscriber
  @subscriber
end

Instance Method Details

#action=(action) ⇒ Object 



140
141
142
143
 
# File 'lib/bunny-pub-sub/services_manager.rb', line 140

def action=(action)
  valid_action? action
  @action = action
end

#cancel_and_remove_subscriber ⇒ Object 



175
176
177
178
179
180
 
# File 'lib/bunny-pub-sub/services_manager.rb', line 175

def cancel_and_remove_subscriber
  return if @subscriber.nil?

  @subscriber.cancel_subscriber
  @subscriber = nil
end

#create_and_start_subscriber(subscriber_config, action, results_publisher) ⇒ Object 



155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
 
# File 'lib/bunny-pub-sub/services_manager.rb', line 155

def create_and_start_subscriber(subscriber_config,
                                action,
                                results_publisher)

  subscriber_created?

  @subscriber_config = subscriber_config
  @results_publisher = results_publisher

  valid_action? action
  @action = action

  @subscriber = Subscriber.new subscriber_config, results_publisher
  start_subscriber
end

#create_publisher(publisher_config) ⇒ Object 



129
130
131
132
 
# File 'lib/bunny-pub-sub/services_manager.rb', line 129

def create_publisher(publisher_config)
  publisher_created?
  @publisher = Publisher.new publisher_config
end

#create_subscriber_without_action(subscriber_config, results_publisher) ⇒ Object 



145
146
147
148
149
150
151
152
153
 
# File 'lib/bunny-pub-sub/services_manager.rb', line 145

def create_subscriber_without_action(subscriber_config,
                                     results_publisher)

  subscriber_created?

  @subscriber_config = subscriber_config
  @results_publisher = results_publisher
  @subscriber = Subscriber.new subscriber_config, results_publisher
end

#remove_all ⇒ Object 



182
183
184
185
 
# File 'lib/bunny-pub-sub/services_manager.rb', line 182

def remove_all
  remove_publisher
  cancel_and_remove_subscriber
end

#remove_publisher ⇒ Object 



134
135
136
137
138
 
# File 'lib/bunny-pub-sub/services_manager.rb', line 134

def remove_publisher
  return if @publisher.nil?

  @publisher = nil
end

#start_subscriber ⇒ Object 



171
172
173
 
# File 'lib/bunny-pub-sub/services_manager.rb', line 171

def start_subscriber
  @subscriber.start_subscriber(@action)
end