Eh main/feature/consumer

[eHattori]

✨ New Feature

The consumer with an include in class and with a method that process payload from the message:

class TestWorker
  include PipefyMessage::Worker
  pipefymessage_options broker: "aws", queue_name: "pipefy-local-queue"

  def perform(message)
    puts message
  end
end

Create abstraction to implement any broker

Refactor

Refactor Publisher to the same model of the consumer

PipefyMessage::Publisher.new.publish({ "teste": "teste"}, "pipefy-local-topic")

🗂 Related cards

[Async] Create Consumer Abstraction that receive the method

[looslidias]

Great work here.

BTW, really liked to have those comments for doubts and some decision making.

IMHO, let's move forward within these changes and keep improving through some risk mapping and also needs from other teams