lib/rabbit_carrots/connection.rb in rabbit_carrots-0.1.14 vs lib/rabbit_carrots/connection.rb in rabbit_carrots-0.1.15
- old
+ new
@@ -2,11 +2,11 @@
module RabbitCarrots
class Connection
include ::Singleton
attr_reader :connection
-
+
def initialize
@connection = Bunny.new(
host: RabbitCarrots.configuration.rabbitmq_host,
port: RabbitCarrots.configuration.rabbitmq_port,
user: RabbitCarrots.configuration.rabbitmq_user,
@@ -14,13 +14,13 @@
vhost: RabbitCarrots.configuration.rabbitmq_vhost
)
@connection.start
end
-
+
def channel
@channel ||= ConnectionPool.new do
connection.create_channel
end
end
- end
+ end
end