Sha256: 2c416e67b95f00cea098895d9dba8845e234871a23f595df8b7ad2bc0763acd8
Contents?: true
Size: 569 Bytes
Versions: 2
Compression:
Stored size: 569 Bytes
Contents
# enconding: utf-8 require 'mutx' require 'socket' module Mutx module Workers class Listener include Sidekiq::Worker def perform(result_id) tcp_port = result.id.to_s[-4..-1].to_i #server = TCPServer.new tcp_port # Server bound to port tcp_port ########################### #begin # server = TCPServer.new tcp_port # Server bound to port tcp_port @running = true Thread.start("#{result.mutx_command}") do |command| end end end end end
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
mutx-0.1.4 | lib/mutx/background_jobs/workers/listener.rb |
mutx-0.1.3 | lib/mutx/background_jobs/workers/listener.rb |