class MessageDriver::Destination::Base

Attributes

adapter[R]
dest_options[R]
message_props[R]
name[R]

Public Class Methods

new(adapter, name, dest_options, message_props) click to toggle source
# File lib/message_driver/destination.rb, line 6
def initialize(adapter, name, dest_options, message_props)
  @adapter = adapter
  @name = name
  @dest_options = dest_options
  @message_props = message_props
end

Public Instance Methods

after_initialize(_adapter_context) click to toggle source
# File lib/message_driver/destination.rb, line 21
def after_initialize(_adapter_context)
  # does nothing, feel free to override as needed
end
consumer_count() click to toggle source
# File lib/message_driver/destination.rb, line 33
def consumer_count
  current_adapter_context.consumer_count(self)
end
message_count() click to toggle source
# File lib/message_driver/destination.rb, line 25
def message_count
  current_adapter_context.message_count(self)
end
middleware() click to toggle source
# File lib/message_driver/destination.rb, line 37
def middleware
  @middleware ||= Middleware::MiddlewareStack.new(self)
end
pop_message(options = {}) click to toggle source
# File lib/message_driver/destination.rb, line 17
def pop_message(options = {})
  current_adapter_context.pop_message(self, options)
end
publish(body, headers = {}, properties = {}) click to toggle source
# File lib/message_driver/destination.rb, line 13
def publish(body, headers = {}, properties = {})
  current_adapter_context.publish(self, body, headers, properties)
end
subscribe(options = {}, &consumer) click to toggle source
# File lib/message_driver/destination.rb, line 29
def subscribe(options = {}, &consumer)
  current_adapter_context.subscribe(self, options, &consumer)
end

Private Instance Methods

client() click to toggle source
# File lib/message_driver/destination.rb, line 47
def client
  @client ||= adapter.broker.client
end
current_adapter_context() click to toggle source
# File lib/message_driver/destination.rb, line 43
def current_adapter_context
  adapter.broker.client.current_adapter_context
end