Module: OMQ

Defined in:
lib/omq/cli.rb,
lib/omq/cli/pair.rb,
lib/omq/cli/pipe.rb,
lib/omq/cli/term.rb,
lib/omq/cli/config.rb,
lib/omq/cli/pub_sub.rb,
lib/omq/cli/req_rep.rb,
lib/omq/cli/version.rb,
lib/omq/cli/formatter.rb,
lib/omq/cli/push_pull.rb,
lib/omq/cli/cli_parser.rb,
lib/omq/cli/radio_dish.rb,
lib/omq/cli/base_runner.rb,
lib/omq/cli/pipe_worker.rb,
lib/omq/cli/socket_setup.rb,
lib/omq/cli/client_server.rb,
lib/omq/cli/router_dealer.rb,
lib/omq/cli/ractor_helpers.rb,
lib/omq/cli/routing_helper.rb,
lib/omq/cli/scatter_gather.rb,
lib/omq/cli/parallel_worker.rb,
lib/omq/cli/transient_monitor.rb,
lib/omq/cli/expression_evaluator.rb

Defined Under Namespace

Modules: CLI

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.incoming_proc ⇒ Proc? (readonly)

Returns registered incoming message transform.

Returns:

  • (Proc, nil) —

    registered incoming message transform



33
34
35
 
# File 'lib/omq/cli.rb', line 33

def incoming_proc
  @incoming_proc
end

.outgoing_proc ⇒ Proc? (readonly)

Returns registered outgoing message transform.

Returns:

  • (Proc, nil) —

    registered outgoing message transform



31
32
33
 
# File 'lib/omq/cli.rb', line 31

def outgoing_proc
  @outgoing_proc
end

Class Method Details

.incoming {|Array<String>| ... } ⇒ Proc

Registers an incoming message transform (used by -r scripts).

Yields:

  • (Array<String>) —

    message parts after receiving

Returns:

  • (Proc) 


45
 
# File 'lib/omq/cli.rb', line 45

def incoming(&block) = @incoming_proc = block

.outgoing {|Array<String>| ... } ⇒ Proc

Registers an outgoing message transform (used by -r scripts).

Yields:

  • (Array<String>) —

    message parts before sending

Returns:

  • (Proc) 


39
 
# File 'lib/omq/cli.rb', line 39

def outgoing(&block) = @outgoing_proc = block