Class: EventQ::QueueMessage

Inherits:

Object

• Object
• EventQ::QueueMessage

Extended by:

ClassKit

Defined in:

lib/eventq/eventq_base/queue_message.rb

Instance Method Summary

• #initialize ⇒ QueueMessage constructor

  A new instance of QueueMessage.

• #sign(provider) ⇒ Object

  Creates a signature for the message.

Constructor Details

#initialize ⇒ QueueMessage

Returns a new instance of QueueMessage.

# File 'lib/eventq/eventq_base/queue_message.rb', line 16

def initialize
  @retry_attempts = 0
  @created = Time.now.to_f
  @id = SecureRandom.uuid
  @context = {}
end

Instance Method Details

#sign(provider) ⇒ Object

Creates a signature for the message

Parameters:

• provider (EventQ::SignatureProviders::Sha256SignatureProvider) —

  Signature provider that implements a write method

# File 'lib/eventq/eventq_base/queue_message.rb', line 27

def sign(provider)
  return unless EventQ::Configuration.signature_secret

  self.signature = provider.write(message: self, secret: EventQ::Configuration.signature_secret)
end