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