Class: Lanes::API::PubSub

Inherits:
Object
  • Object
show all
Defined in:
lib/lanes/api/pub_sub.rb

Class Method Summary collapse

Class Method Details

.initialize(api = nil) ⇒ Object 



10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
 
# File 'lib/lanes/api/pub_sub.rb', line 10

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

.publish(channel, data) ⇒ Object 



6
7
8
 
# File 'lib/lanes/api/pub_sub.rb', line 6

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