Class: EventQ::RabbitMq::StatusChecker
- Inherits:
-
Object
- Object
- EventQ::RabbitMq::StatusChecker
- Defined in:
- lib/eventq_rabbitmq/rabbitmq_status_checker.rb
Instance Method Summary collapse
- #event_type?(event_type) ⇒ Boolean
-
#initialize(client:, queue_manager:) ⇒ StatusChecker
constructor
A new instance of StatusChecker.
- #queue?(queue) ⇒ Boolean
Constructor Details
#initialize(client:, queue_manager:) ⇒ StatusChecker
Returns a new instance of StatusChecker.
5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 |
# File 'lib/eventq_rabbitmq/rabbitmq_status_checker.rb', line 5 def initialize(client:, queue_manager:) if client == nil raise 'client must be specified.'.freeze end @client = client if queue_manager == nil raise 'queue_manager must be specified.'.freeze end @queue_manager = queue_manager @event_raised_exchange = EventRaisedExchange.new end |
Instance Method Details
#event_type?(event_type) ⇒ Boolean
42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 |
# File 'lib/eventq_rabbitmq/rabbitmq_status_checker.rb', line 42 def event_type?(event_type) outcome = true begin connection = @client.get_connection channel = connection.create_channel @queue_manager.get_exchange(channel, @event_raised_exchange) rescue outcome = false ensure channel.close if channel connection.close if connection end outcome end |
#queue?(queue) ⇒ Boolean
23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 |
# File 'lib/eventq_rabbitmq/rabbitmq_status_checker.rb', line 23 def queue?(queue) outcome = true begin connection = @client.get_connection channel = connection.create_channel _queue_name = EventQ.create_queue_name(queue.name) channel.queue(_queue_name, :durable => true) rescue outcome = false ensure channel.close if channel connection.close if connection end outcome end |