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