Class: RabbitJobs::Publisher::Base

Inherits:
Object
  • Object
show all
Defined in:
lib/rabbit_jobs/publisher/base.rb

Overview

Abstract publisher.

Direct Known Subclasses

Amqp, Sync, Test

Class Method Summary collapse

Class Method Details

.cleanupObject



6
7
8
# File 'lib/rabbit_jobs/publisher/base.rb', line 6

def cleanup
  fail NotImplementedError
end

.direct_publish_to(_routing_key, _payload, _ex = {}) ⇒ Object



14
15
16
# File 'lib/rabbit_jobs/publisher/base.rb', line 14

def direct_publish_to(_routing_key, _payload, _ex = {})
  fail NotImplementedError
end

.publish_to(_routing_key, _klass, *_params) ⇒ Object



10
11
12
# File 'lib/rabbit_jobs/publisher/base.rb', line 10

def publish_to(_routing_key, _klass, *_params)
  fail NotImplementedError
end

.purge_queue(*_routing_keys) ⇒ Object



18
19
20
# File 'lib/rabbit_jobs/publisher/base.rb', line 18

def purge_queue(*_routing_keys)
  fail NotImplementedError
end

.queue_status(_routing_key) ⇒ Object



22
23
24
# File 'lib/rabbit_jobs/publisher/base.rb', line 22

def queue_status(_routing_key)
  fail NotImplementedError
end