module Pheromone

Encapsulates WaterDrop::Message

This module is used for sending messages to Kafka Dispatch method can be :sync or :async When dispatch_method is async, the message object is passed to a job the job needs to call `send!` on the WaterDrop::Message object

calls a proc or method

validate message options provided to publish method in Publishable concern

Constants

VERSION

Public Class Methods

config() click to toggle source

return config

# File lib/pheromone.rb, line 10
def config
  Config.config
end

enabled?() click to toggle source

# File lib/pheromone.rb, line 14
def enabled?
  Pheromone.config.enabled
end

setup(&block) click to toggle source

Provides a block to override default config

# File lib/pheromone.rb, line 19
def setup(&block)
  Config.setup(&block)
end