Class: OMQ::Ractor::TopicShareableConnection

Inherits:

SimpleDelegator

• Object
• SimpleDelegator
• OMQ::Ractor::TopicShareableConnection

Includes:

TransparentDelegator

Defined in:

lib/omq/ractor.rb

Overview

Topic-aware shareable wrapper for inproc PUB/SUB.

Instance Method Summary

• #send_message(parts) ⇒ void

Methods included from TransparentDelegator

#is_a?

Instance Method Details

#send_message(parts) ⇒ void

This method returns an undefined value.

Parameters:

• parts (Array<String>) —

  message frames to freeze and send

# File 'lib/omq/ractor.rb', line 188

def send_message(parts)
  super(::Ractor.make_shareable(parts))
end