lib/ocean/zero_log.rb
def pull_server(address=PUSH_ADDRESS)
    #puts "Starting PULL server"
    puller = context.socket(ZMQ::PULL)
    #puts "Binding to the PULL socket"
    puller.bind("tcp://*:10000")
    # Set up the PUSH socket
    pusher = context.socket(ZMQ::PUSH)
    #puts "Binding to the PUSH socket"
    pusher.bind(address)
    # Trap everything
    trap_int(puller, pusher)
    # Connect PULL to PUSH via a queue
    ZMQ::Device.new(ZMQ::QUEUE, puller, pusher)
  end
#
# This is the PULL to PUSH server. It pushes the received data over IPC 
# round-robin fashion to each PULL log worker on the machine.
#
This is the PULL to PUSH server. It pushes the received data over IPC
round-robin fashion to each PULL log worker on the machine.
This is the PULL to PUSH server . It pushes the received data over IPC round - robin fashion to each PULL log worker on the machine .
def pull_server(address=PUSH_ADDRESS)
    puller = context.socket(ZMQ::PULL)
    puller.bind("tcp://*:10000")
    pusher = context.socket(ZMQ::PUSH)
    pusher.bind(address)
    trap_int(puller, pusher)
    ZMQ::Device.new(ZMQ::QUEUE, puller, pusher)
  end
def pull_server ( address = PUSH_ADDRESS ) puller = context . socket ( ZMQ :: PULL ) puller . bind ( "tcp://*:10000" ) pusher = context . socket ( ZMQ :: PUSH ) pusher . bind ( address ) trap_int ( puller , pusher ) ZMQ :: Device . new ( ZMQ :: QUEUE , puller , pusher ) end
This is the PULL to PUSH server.
This is the PULL to PUSH server .
#puts "Starting PULL server" #puts "Binding to the PULL socket" # Set up the PUSH socket #puts "Binding to the PUSH socket" # Trap everything # Connect PULL to PUSH via a queue
address