module Emque::Producing
Constants
- ConfigurationError
- VERSION
Attributes
configuration[W]
publisher[RW]
Public Class Methods
configuration()
click to toggle source
# File lib/emque/producing/producing.rb, line 25 def configuration @configuration ||= Emque::Producing::Configuration.new end
configure() { |configuration| ... }
click to toggle source
# File lib/emque/producing/producing.rb, line 21 def configure yield(configuration) end
hostname()
click to toggle source
# File lib/emque/producing/producing.rb, line 29 def hostname return @hostname unless @hostname.nil? @hostname = Socket.gethostname @hostname end
logger()
click to toggle source
# File lib/emque/producing/producing.rb, line 47 def logger Emque::Producing::Logging.logger end
logger=(log)
click to toggle source
# File lib/emque/producing/producing.rb, line 51 def logger=(log) Emque::Producing::Logging.logger = log end
message(opts = {})
click to toggle source
# File lib/emque/producing/producing.rb, line 7 def message(opts = {}) with_changeset = opts.fetch(:with_changeset) { false } Module.new do define_singleton_method(:included) do |descendant| if with_changeset descendant.send(:include, ::Emque::Producing::MessageWithChangeset) else descendant.send(:include, ::Emque::Producing::Message) end end end end