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



35
36
37
 
# File 'lib/omq/cli.rb', line 35

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) 


51
52
53
 
# File 'lib/omq/cli.rb', line 51

def incoming(&block)
  @incoming_proc = block
end

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

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

Yields:

  • (Array<String>) —

    message parts before sending

Returns:

  • (Proc) 


42
43
44
 
# File 'lib/omq/cli.rb', line 42

def outgoing(&block)
  @outgoing_proc = block
end