lib/basquiat/adapters/rabbitmq/session.rb in basquiat-1.3.0.pre.1 vs lib/basquiat/adapters/rabbitmq/session.rb in basquiat-1.3.0

@@ -1,8 +1,10 @@
+# frozen_string_literal: true
 module Basquiat
   module Adapters
     class RabbitMq
+      # A RabbitMQ session.
       class Session
         attr_reader :channel
 
         def initialize(channel, session_options = {})
           @channel = channel
@@ -30,9 +32,13 @@
 
         def queue
           @queue ||= channel.queue(@options[:queue][:name],
                                    durable:   @options[:queue][:durable],
                                    arguments: (@options[:queue][:options] || {}))
+        end
+
+        def queue_name
+          queue.name
         end
 
         def exchange
           @exchange ||= channel.topic(@options[:exchange][:name],
                                       durable:   @options[:exchange][:durable],