Method: CarbonMU::ReadSocket#initialize

Defined in:
lib/carbonmu/ipc/read_socket.rb

#initialize(port = '*') ⇒ ReadSocket

Returns a new instance of ReadSocket.



6
7
8
9
 
# File 'lib/carbonmu/ipc/read_socket.rb', line 6

def initialize(port = '*')
  @zmq_socket = Celluloid::ZMQ::PullSocket.new
  @zmq_socket.bind("tcp://127.0.0.1:#{port}")
end