module BloomRemitClient

Constants

PRODUCTION
STAGING
TXN_UPDATES_CHANNEL
VERSION

Public Class Methods

configure_message_bus_client_worker!() click to toggle source

# File lib/bloom_remit_client.rb, line 38
def self.configure_message_bus_client_worker!
  if configuration.on_txn_update.blank?
    fail "`on_txn_update` must be defined"
  end

  token = [
    configuration.partner_id,
    configuration.api_secret,
  ].join(":")
  token = Base64.strict_encode64(token)

  MessageBusClientWorker.subscribe(configuration.host, {
    headers: {
      "Authorization" => "Basic #{token}"
    },
    channels: {
      TXN_UPDATES_CHANNEL => { 
        processor: configuration.on_txn_update,
        message_id: 0,
      },
    }
  })
end