lib/ocean/zero_log.rb
def connect_to_sub_server(sub_push="sub_push")
    # Next create the PUB socket and connect it to the other thread
    #puts "Creating the PUB socket"
    $log_publisher = context.socket(ZMQ::PUB) 
    trap_int($log_publisher)
    #puts "Connecting to the SUB server"
    $log_publisher.connect("inproc://#{sub_push}")
  end
#
# This is the ZeroMQ context. We only need one per process, thus we
# store it in a class variable.
#
This is the ZeroMQ context. We only need one per process, thus we
store it in a class variable.
This is the ZeroMQ context . We only need one per process thus we store it in a class variable .
def connect_to_sub_server(sub_push="sub_push")
    $log_publisher = context.socket(ZMQ::PUB) 
    trap_int($log_publisher)
    $log_publisher.connect("inproc://#{sub_push}")
  end
def connect_to_sub_server ( sub_push = "sub_push" ) $log_publisher = context . socket ( ZMQ :: PUB ) trap_int ( $log_publisher ) $log_publisher . connect ( "inproc://#{sub_push}" ) end
This is the ZeroMQ context.
This is the ZeroMQ context .
# Next create the PUB socket and connect it to the other thread #puts "Creating the PUB socket" #puts "Connecting to the SUB server"
sub_push