class Plugin::Base

Public Class Methods

new(client) click to toggle source
# File lib/plugin/base.rb, line 3
def initialize(client)
  @client = client
  @subscription_mode = ::Mqjob.config.subscription_mode
end

Public Instance Methods

close_listen() click to toggle source
# File lib/plugin/base.rb, line 12
def close_listen; end
close_publish() click to toggle source
# File lib/plugin/base.rb, line 13
def close_publish; end
listen(topic, worker, opts = {}) click to toggle source
# File lib/plugin/base.rb, line 8
def listen(topic, worker, opts = {}); end
publish(topic, msg, opts = {}) click to toggle source
# File lib/plugin/base.rb, line 10
def publish(topic, msg, opts = {}); end