Class: SharedBroker::Adapters::Base

Inherits:
Object
  • Object
show all
Defined in:
lib/shared_broker/adapters/base.rb

Direct Known Subclasses

InMemory, Kafka, RabbitMQ, Redis

Instance Method Summary collapse

Instance Method Details

#publish(topic, message, correlation_id: nil) ⇒ Object

Raises:

  • (NotImplementedError) 


6
7
8
 
# File 'lib/shared_broker/adapters/base.rb', line 6

def publish(topic, message, correlation_id: nil)
  raise NotImplementedError, "#{self.class.name} must implement #publish"
end

#subscribe(topic, queue_name, max_retries: 3, backoff_base: 2, &block) ⇒ Object

Raises:

  • (NotImplementedError) 


10
11
12
 
# File 'lib/shared_broker/adapters/base.rb', line 10

def subscribe(topic, queue_name, max_retries: 3, backoff_base: 2, &block)
  raise NotImplementedError, "#{self.class.name} must implement #subscribe"
end