postal/lib/postal/rabbit_mq.rb

# frozen_string_literal: true

require "postal/config"
require "bunny"

module Postal
  module RabbitMQ

    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(
        hosts: bunny_host,
        port: Postal.config.rabbitmq&.port || 5672,
        tls: Postal.config.rabbitmq&.tls || false,
        verify_peer: Postal.config.rabbitmq&.verify_peer || true,
        tls_ca_certificates: Postal.config.rabbitmq&.tls_ca_certificates || ["/etc/ssl/certs/ca-certificates.crt"],
        username: Postal.config.rabbitmq&.username || "guest",
        password: Postal.config.rabbitmq&.password || "guest",
        vhost: Postal.config.rabbitmq&.vhost || nil
      )
      conn.start
      conn
    end

    def self.create_channel
      conn = create_connection
      conn.create_channel(nil, Postal.config.workers.threads)
    end

  end
end