brantfaircloth

# assume the following directory structure where contents of doc/ 
# and source/ are already checked into repo., with the exception 
# of the _build directory (i,e. you can check in _themes or _sources 
# or whatever else).
#
# proj/
#    source/
#    doc/

# remove doc/_build/html if present

octplane

require 'rubygems'
require 'mongo'

module MongoPubSub
  QUEUES_COLLECTION = 'queues'
  class EndSubscriptionException < Exception; end
  class Publisher
    def initialize(queue_name, mongo_connection)
      # Initialize queue collection as a capped collection
      if not mongo_connection[QUEUES_COLLECTION].collection_names.include?(queue_name)