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