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