Class: WideRabbitMQRoom

Inherits:
BaseRabbitMQRoom show all
Defined in:
lib/postcard_rb/dispatchers/RabbitMQ/routings/Wide/WideRabbitMQRoom.rb

Instance Method Summary collapse

Methods inherited from BaseRabbitMQRoom

#subscribe

Constructor Details

#initialize(name:, exclusive: false, autoDelete: false, channel:, exchange:) ⇒ WideRabbitMQRoom

Returns a new instance of WideRabbitMQRoom.



4
5
6
7
8
9
10
11
 
# File 'lib/postcard_rb/dispatchers/RabbitMQ/routings/Wide/WideRabbitMQRoom.rb', line 4

def initialize name:, exclusive: false, autoDelete: false, channel:, exchange:
  queueName = ""
  queueName = name if exclusive

  queue = channel.queue(queueName).bind(exchange, :auto_delete => autoDelete)

  super(channel: channel, queue: queue, exclusive: exclusive)
end