class Pheme::MessageHandler

Attributes

message[R]
message_attributes[R]
metadata[R]
timestamp[R]

Public Class Methods

new(message:, metadata: {}, message_attributes: {}) click to toggle source
# File lib/pheme/message_handler.rb, line 5
def initialize(message:, metadata: {}, message_attributes: {})
  @message = message
  @metadata = metadata
  @message_attributes = message_attributes
end

Public Instance Methods

handle() click to toggle source
# File lib/pheme/message_handler.rb, line 11
def handle
  raise NotImplementedError
end