class RFlow::Configuration::ZMQConnection
Subclass of {Connection} for ZMQ connections and their required options.
Public Class Methods
default_options()
click to toggle source
Default options required for ZeroMQ connection. @return [Hash]
# File lib/rflow/configuration/connection.rb, line 77 def self.default_options { 'output_socket_type' => 'PUSH', 'output_address' => lambda{|conn| "ipc://rflow.#{conn.uuid}"}, 'output_responsibility' => 'connect', 'input_socket_type' => 'PULL', 'input_address' => lambda{|conn| "ipc://rflow.#{conn.uuid}"}, 'input_responsibility' => 'bind', } end