Class: Refinery::Publisher

Inherits:
Object
  • Object
show all
Includes:
Loggable
Defined in:
lib/refinery/publisher.rb

Overview

Base class for publishers to be implemented by subclasses.

Instance Method Summary collapse

Methods included from Loggable

#logger

Constructor Details

#initialize(waiting_queue) ⇒ Publisher

Initialize the publisher with the queue to publish messages to.



7
8
9
# File 'lib/refinery/publisher.rb', line 7

def initialize(waiting_queue)
  @waiting_queue = waiting_queue
end