class Basquiat::Adapters::BaseMessage

The simplest Message class. It's encouraged to tailor it to your adapter needs (hence BaseMessage).

Attributes

action[R]

Public Class Methods

new(message) click to toggle source

@param message [Object] It's assumed that message is some kind of JSON @note All unknown messages will be delegated to the resulting Hash

Calls superclass method
# File lib/basquiat/adapters/base_message.rb, line 11
def initialize(message)
  @message = Basquiat::Json.decode(message)
  super(@message)
  @action = :ack
end

Public Instance Methods

ack() click to toggle source

@!group Action Setters Sets the action to be taken after processing to be an ack. Here just in case as the default is to acknowledge the message.

# File lib/basquiat/adapters/base_message.rb, line 20
def ack
  @action = :ack
end
nack() click to toggle source

Sets the action to be taken after processing to be an nack / reject

# File lib/basquiat/adapters/base_message.rb, line 25
def nack
  @action = :nack
end
requeue() click to toggle source

Sets the action to be taken after processing to be a requeue

# File lib/basquiat/adapters/base_message.rb, line 30
def requeue
  @action = :requeue
end