Class: ExplicitRabbitMQRoom

Inherits:
BaseRabbitMQRoom show all
Defined in:
lib/postcard_rb/dispatchers/RabbitMQ/routings/Explicit/ExplicitRabbitMQRoom.rb

Instance Method Summary collapse

Methods inherited from BaseRabbitMQRoom

#subscribe

Constructor Details

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

Returns a new instance of ExplicitRabbitMQRoom.



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

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

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

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