Class: RFlow::Configuration::ZMQConnection

Inherits:
Connection show all
Defined in:
lib/rflow/configuration/connection.rb

Overview

STI Subclass for ZMQ connections and their required options

Class Method Summary collapse

Methods inherited from Connection

#all_required_options_present?, #brokers, #merge_default_options!, required_options

Methods included from UUIDKeyed

included

Class Method Details

.default_options ⇒ Object 



56
57
58
59
60
61
62
63
64
65
 
# File 'lib/rflow/configuration/connection.rb', line 56

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