require_relative “<%= name.capitalize %>/version”
module <%= name.capitalize %>
class Main include SubZero::Common def initialize service @config = service.config log "INITing socket" end def poll_sockets print '.' sleep 1 end def ping log "ping..." end ####### private ####### def send_announce_packet $sent = Time.now @socket.send_string "SRV", ZMQ::SNDMORE @socket.send_string 0.to_s, ZMQ::SNDMORE @socket.send_string "UP", ZMQ::SNDMORE payload = { id: @config['service']['id'], sid: @config['service']['sid'] }.to_msgpack @socket.send_string payload end def init_socket @context = ZMQ::Context.new @socket = @context.socket ZMQ::DEALER @socket.identity = @config['service']['id'] @socket.connect "tcp://#{@config['service']['broker_host']}:#{@config['service']['broker_port']}" @poller = ZMQ::Poller.new @poller.register @socket, ZMQ::POLLIN end end
end