Module: OMQ::QueueWritable

Included in:
Writable
Defined in:
lib/omq/queue_interface.rb

Overview

Async::Queue-compatible write interface.

Automatically included by Writable. Provides #enqueue, #push, and #signal so sockets can be used where an Async::Queue is expected.

Instance Method Summary collapse

Instance Method Details

#enqueue(*messages) ⇒ self Also known as: push

Enqueues one or more messages for sending.

Parameters:

  • messages (String, Array<String>)

Returns:

  • (self) 


63
64
65
66
 
# File 'lib/omq/queue_interface.rb', line 63

def enqueue(*messages)
  messages.each { |msg| send(msg) }
  self
end