Class: RFlow::Configuration::ZMQConnection

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

Overview

Subclass of Connection for ZMQ connections and their required options.

Instance Attribute Summary

Attributes inherited from Connection

#input_port, #options, #output_port

Class Method Summary collapse

Methods inherited from Connection

#brokers, required_options

Class Method Details

.default_options ⇒ Hash

Default options required for ZeroMQ connection.

Returns:

  • (Hash) 


77
78
79
80
81
82
83
84
85
86
 
# 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