Class: OMQ::CLI::RepRunner

Inherits:
BaseRunner show all
Defined in:
lib/omq/cli/req_rep.rb

Overview

Runner for REP sockets (synchronous request-reply server).

Instance Attribute Summary

Attributes inherited from BaseRunner

#config, #sock

Instance Method Summary collapse

Methods inherited from BaseRunner

#initialize

Constructor Details

This class inherits a constructor from OMQ::CLI::BaseRunner

Instance Method Details

#call(task) ⇒ Object 



48
49
50
51
52
53
54
 
# File 'lib/omq/cli/req_rep.rb', line 48

def call(task)
  if config.parallel
    run_parallel_workers(:REP)
  else
    super
  end
end