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