module Gorsse
Constants
- VERSION
Public Class Methods
close_connections()
click to toggle source
# File lib/gorsse.rb, line 20 def self.close_connections @conn && @conn.close @receiver_conn && @receiver_conn.close Connection::ZCTX.terminate end
config()
click to toggle source
# File lib/gorsse.rb, line 16 def self.config @config ||= Config.new end
configure(&block)
click to toggle source
# File lib/gorsse.rb, line 12 def self.configure(&block) block.call(config) end
conn()
click to toggle source
# File lib/gorsse.rb, line 26 def self.conn @conn ||= Connection.new(config.handler, mode: :push, method: :connect) end
receiver_conn()
click to toggle source
# File lib/gorsse.rb, line 30 def self.receiver_conn @receiver_conn ||= Connection.new(config.receiver, mode: :pull, method: :bind) end
start_receiver_loop!()
click to toggle source
# File lib/gorsse.rb, line 34 def self.start_receiver_loop! loop do message = receiver_conn.receive command = Command.new(message) command.run! end end