Method: LontaraUtilities::RMQ::Server::Subscriber#initialize

Defined in:
lib/lontara_utilities/rmq/server/subscriber.rb

#initialize(connection, queue:) ⇒ Subscriber

Returns a new instance of Subscriber.



8
9
10
11
 
# File 'lib/lontara_utilities/rmq/server/subscriber.rb', line 8

def initialize(connection, queue:)
  @channel = connection.channel
  @queue = channel.queue(queue, durable: true)
end