class EventQ::QueueMessage

Public Class Methods

new() click to toggle source
# File lib/eventq/eventq_base/queue_message.rb, line 14
def initialize
  @retry_attempts = 0
  @created = Time.now.to_f
  @id = SecureRandom.uuid
  @context = {}
end

Public Instance Methods

sign(provider) click to toggle source

Creates a signature for the message

@param provider [EventQ::SignatureProviders::Sha256SignatureProvider] Signature provider that implements

a write method
# File lib/eventq/eventq_base/queue_message.rb, line 25
def sign(provider)
  return unless EventQ::Configuration.signature_secret

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