class Announce::Adapters::BaseAdapter::Destination
Attributes
action[RW]
options[RW]
subject[RW]
Public Class Methods
app()
click to toggle source
# File lib/announce/adapters/base_adapter.rb, line 95 def self.app ::Announce.options[:app_name] end
delimiter()
click to toggle source
# File lib/announce/adapters/base_adapter.rb, line 91 def self.delimiter ::Announce.options[:queue_name_delimiter] end
name_for(subject, action)
click to toggle source
# File lib/announce/adapters/base_adapter.rb, line 73 def self.name_for(subject, action) [prefix, namespace, subject, action].join(delimiter) end
namespace()
click to toggle source
# File lib/announce/adapters/base_adapter.rb, line 99 def self.namespace ::Announce.options[:namespace] end
new(subject, action, options = {})
click to toggle source
# File lib/announce/adapters/base_adapter.rb, line 77 def initialize(subject, action, options = {}) @subject = subject @action = action @options = options || {} end
prefix()
click to toggle source
# File lib/announce/adapters/base_adapter.rb, line 87 def self.prefix ::Announce.options[:queue_name_prefix] end
Public Instance Methods
create()
click to toggle source
# File lib/announce/adapters/base_adapter.rb, line 65 def create raise NotImplementedError.new("You must implement create.") end
name(subject = @subject, action = @action)
click to toggle source
# File lib/announce/adapters/base_adapter.rb, line 83 def name(subject = @subject, action = @action) self.class.name_for(subject, action) end
publish(message, options = {})
click to toggle source
# File lib/announce/adapters/base_adapter.rb, line 61 def publish(message, options = {}) raise NotImplementedError.new("You must implement publish.") end
verify()
click to toggle source
# File lib/announce/adapters/base_adapter.rb, line 69 def verify raise NotImplementedError.new("You must implement verify.") end