Contents

module Lanes
    module API

        class PubSub

            def self.publish(channel, data)
                MessageBus.publish channel, data
            end

            def self.initialize(api=nil)
                return unless Extensions.require_pub_sub?
                require "oj"
                require_relative "updates"
                require 'message_bus'
                api.use MessageBus::Rack::Middleware if api

                # Use OJ - it encodes dates properly as ISO 8601
                # https://github.com/moment/moment/issues/1407
                Oj.mimic_JSON()
                # # Requiring json here seems to stop conflicts when requiring json in other files.
                begin
                    require 'json'
                rescue Exception
                    # ignore
                end
                ::MessageBus.redis_config = Lanes.config.redis
                Updates.relay!
            end

        end

    end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
lanes-0.1.9	lib/lanes/api/pub_sub.rb
lanes-0.1.8	lib/lanes/api/pub_sub.rb
lanes-0.1.7	lib/lanes/api/pub_sub.rb
lanes-0.1.6	lib/lanes/api/pub_sub.rb
lanes-0.1.5	lib/lanes/api/pub_sub.rb