Class: Hawking::Queue

Inherits:

Object

Object
Hawking::Queue

show all

Defined in:: lib/hawking.rb

Instance Method Summary collapse

#initialize ⇒ Queue constructor

A new instance of Queue.
#put(queue, data) ⇒ Object

Constructor Details

#initialize ⇒ `Queue`

Returns a new instance of Queue.



44
45
46

# File 'lib/hawking.rb', line 44

def initialize
  @socket = TCPSocket.open "127.0.0.1", 4481
end

Instance Method Details

#put(queue, data) ⇒ `Object`

# File 'lib/hawking.rb', line 48

def put(queue, data)
  info = JSON.generate queue: queue, data: data

  @socket.write info
  @socket.close
end