Contents

module Basquiat
  module Adapters
    class BaseMessage < SimpleDelegator
      attr_reader :action

      def initialize(message)
        @message = Basquiat::Json.decode(message)
        super(@message)
        @action = :ack
      end

      def ack?
        fail Basquiat::Errors::SubclassResponsibility
      end

      def unack
        fail Basquiat::Errors::SubclassResponsibility
      end

      def requeue
        fail Basquiat::Errors::SubclassResponsibility
      end

      def delay_redelivery
        fail Basquiat::Errors::SubclassResponsibility
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
basquiat-1.2.0	lib/basquiat/adapters/base_message.rb