Class: Plugin::Base

Inherits:

Object

• Object
• Plugin::Base

Defined in:

lib/plugin/base.rb

Direct Known Subclasses

Pulsar

Instance Method Summary

• #close_listen ⇒ Object
• #close_publish ⇒ Object
• #initialize(client) ⇒ Base constructor

  A new instance of Base.

• #listen(topic, worker, opts = {}) ⇒ Object
• #publish(topic, msg, opts = {}) ⇒ Object

Constructor Details

#initialize(client) ⇒ Base

Returns a new instance of Base.

# File 'lib/plugin/base.rb', line 3

def initialize(client)
  @client = client
  @subscription_mode = ::Mqjob.config.subscription_mode
end

Instance Method Details

#close_listen ⇒ Object

# File 'lib/plugin/base.rb', line 12

def close_listen; end

#close_publish ⇒ Object

# File 'lib/plugin/base.rb', line 13

def close_publish; end

#listen(topic, worker, opts = {}) ⇒ Object

# File 'lib/plugin/base.rb', line 8

def listen(topic, worker, opts = {}); end

#publish(topic, msg, opts = {}) ⇒ Object

# File 'lib/plugin/base.rb', line 10

def publish(topic, msg, opts = {}); end