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