Class: Synapse::Partitioning::MemoryQueueWriter

Inherits:
QueueWriter
  • Object
show all
Defined in:
lib/synapse/partitioning/memory_queue_writer.rb

Overview

Queue writer that pushes message into an in-memory Ruby queue

Instance Method Summary collapse

Constructor Details

#initialize(queue) ⇒ undefined

Parameters:

  • queue (Queue) 


7
8
9
 
# File 'lib/synapse/partitioning/memory_queue_writer.rb', line 7

def initialize(queue)
  @queue = queue
end

Instance Method Details

#put_message(packed, unpacked) ⇒ undefined

Parameters:

  • packed (Object)
  • unpacked (Message)

Returns:

  • (undefined) 


14
15
16
 
# File 'lib/synapse/partitioning/memory_queue_writer.rb', line 14

def put_message(packed, unpacked)
  @queue.push packed
end