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