Class: Synapse::Partitioning::MessageUnpacker

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

Overview

Represents a mechanism for unpacking a message that has been packed for storage in a file or transport from a producer

This implementation simply returns the message as-is

Direct Known Subclasses

JsonMessageUnpacker

Instance Method Summary collapse

Instance Method Details

#unpack_message(packed) ⇒ Message

Parameters:

  • packed (String)

Returns:



22
23
24
# File 'lib/synapse/partitioning/packing.rb', line 22

def unpack_message(packed)
  packed
end