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