ghaymah_dev/postal
1
0
Fork 0
mirror of https://github.com/postalserver/postal.git synced 2026-10-20 11:17:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

added ability to use clustered rabbitmq

Browse Source
This commit is contained in:
Antony Ryabov
2019-04-08 11:08:35 +01:00
committed by Charlie Smurthwaite
parent 1cf5767cd5
commit 9f2e3ca1fa
1 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/postal/rabbit_mq.rb
+9 -1
View File
@@ -5,8 +5,16 @@ module Postal
module RabbitMQ module RabbitMQ
def self.create_connection def self.create_connection
bunny_host = [ 'localhost' ]
if Postal.config.rabbitmq&.host.is_a?(Array)
bunny_host = Postal.config.rabbitmq&.host
elsif Postal.config.rabbitmq&.host.is_a?(String)
bunny_host = [ Postal.config.rabbitmq&.host ]
end
conn = Bunny.new( conn = Bunny.new(
:host => Postal.config.rabbitmq&.host || 'localhost', :hosts => bunny_host,
:port => Postal.config.rabbitmq&.port || 5672, :port => Postal.config.rabbitmq&.port || 5672,
:username => Postal.config.rabbitmq&.username || 'guest', :username => Postal.config.rabbitmq&.username || 'guest',
:password => Postal.config.rabbitmq&.password || 'guest', :password => Postal.config.rabbitmq&.password || 'guest',