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