Sha256: 830988a08271927f067a24cba5da4d0ab19a47515f444b84b54087c83eaf122d
Contents?: true
Size: 1.41 KB
Versions: 22
Compression:
Stored size: 1.41 KB
Contents
module Refinery #:nodoc:
# Base class for publishers to be implemented by subclasses.
class Publisher
include Refinery::Loggable
include Refinery::Queueable
# Initialize the publisher with the queue to publish messages to.
def initialize(waiting_queue_name)
@waiting_queue_name = waiting_queue_name
end
protected
# Get the publish queue name
def waiting_queue_name
@waiting_queue_name
end
# Publish the message. The message will be converted to JSON and pushed
# into the queue associated with the publisher.
def publish(message)
with_queue(waiting_queue_name) do |waiting_queue|
publish_to_queue(waiting_queue, message)
end
end
# Publish the given message if the waiting queue is empty. The message will
# be converted to JSON and pushed into the queue associated with the
# publisher.
def publish_if_empty(message)
with_queue(waiting_queue_name) do |waiting_queue|
publish_to_queue(waiting_queue, message) if waiting_queue.size == 0
end
end
# Publish the given message to the queue. The message will be converted
# to JSON and pushed into the queue associated with the publisher.
def publish_to_queue(queue, message)
logger.debug "Publisher #{self.class.name} sending message: #{message.to_json}"
queue.send_message(Base64.encode64(message.to_json))
end
end
end
Version data entries
22 entries across 22 versions & 2 rubygems