Module: OMQ::SingleFrame

Defined in:
lib/omq/single_frame.rb

Overview

Mixin that rejects multipart messages.

All draft socket types (CLIENT, SERVER, RADIO, DISH, SCATTER, GATHER, PEER, CHANNEL) require single-frame messages for thread-safe atomic operations.

Instance Method Summary collapse

Instance Method Details

#send(message) ⇒ void

This method returns an undefined value.

Sends a message, rejecting multipart messages.

Parameters:

  • message (String, Array<String>) —

    message to send (must be single-frame)

Raises:

  • (ArgumentError) —

    if a multipart message is provided



16
17
18
19
20
21
 
# File 'lib/omq/single_frame.rb', line 16

def send(message)
  if message.is_a?(Array) && message.size > 1
    raise ArgumentError, "#{self.class} does not support multipart messages"
  end
  super
end