module Jackhammer

Constants

VERSION

Attributes

configuration[RW]
connection[W]

Public Class Methods

channel() click to toggle source
# File lib/jackhammer.rb, line 34
def channel
  @channel ||= connection.create_channel
end
client_middleware() click to toggle source
# File lib/jackhammer.rb, line 51
def client_middleware
  configuration.client_middleware
end
configure() { |configuration| ... } click to toggle source
# File lib/jackhammer.rb, line 22
def configure
  @configuration = Configuration.instance
  yield @configuration
end
connection() click to toggle source
# File lib/jackhammer.rb, line 27
def connection
  @connection ||= Bunny.new(
    Jackhammer.configuration.connection_url,
    Jackhammer.configuration.connection_options
  ).start
end
publish_options(options = {}, time = Time.now.utc) click to toggle source
# File lib/jackhammer.rb, line 42
def publish_options(options = {}, time = Time.now.utc)
  configuration.publish_options.dup.merge(options).tap do |opts|
    opts[:timestamp] = time.to_i
    opts[:app_id] ||= configuration.app_name
    opts[:headers] ||= {}
    opts[:headers][:time] ||= time.iso8601
  end
end
server_middleware() click to toggle source
# File lib/jackhammer.rb, line 55
def server_middleware
  configuration.server_middleware
end
topics() click to toggle source
# File lib/jackhammer.rb, line 38
def topics
  @topics ||= TopicManager.topics
end