class Jobi::Config::Rabbitmq

Attributes

auth_mechanism[RW]
automatically_recover[RW]
continuation_timeout[RW]
frame_max[RW]
heartbeat[RW]
host[RW]
network_recovery_interval[RW]
pass[RW]
port[RW]
ssl[RW]
threaded[RW]
user[RW]
vhost[RW]

Public Class Methods

new() click to toggle source
# File lib/jobi/config/rabbitmq.rb, line 9
def initialize
  setup_server_config
  setup_network_config
  setup_processing_config
end

Public Instance Methods

to_h() click to toggle source
# File lib/jobi/config/rabbitmq.rb, line 15
def to_h
  {
    host: @host,
    port: @port,
    user: @user,
    pass: @pass,
    vhost: @vhost,
    auth_mechanism: @auth_mechanism,
    heartbeat: @heartbeat,
    automatically_recover: @automatically_recover,
    network_recovery_interval: @network_recovery_interval,
    ssl: @ssl,
    threaded: @threaded,
    continuation_timeout: @continuation_timeout,
    frame_max: @frame_max
  }
end

Private Instance Methods

setup_network_config() click to toggle source
# File lib/jobi/config/rabbitmq.rb, line 44
def setup_network_config
  @heartbeat = :server
  @automatically_recover = true
  @network_recovery_interval = 5.0
  @ssl = false
end
setup_processing_config() click to toggle source
# File lib/jobi/config/rabbitmq.rb, line 51
def setup_processing_config
  @threaded = true
  @continuation_timeout = 4000
  @frame_max = 131_072
end
setup_server_config() click to toggle source
# File lib/jobi/config/rabbitmq.rb, line 35
def setup_server_config
  @host = '127.0.0.1'
  @port = '5672'
  @user = 'guest'
  @pass = 'guest'
  @vhost = '/'
  @auth_mechanism = 'PLAIN'
end