lib/donaghy/event_subscriber.rb
# local from code in this process
local from code in this process
local from code in this process
def local_subscribe(event_path, queue, class_name)
      logger.info("EventSubscriber: local registering #{event_path} to #{queue}, #{class_name}")
      local_storage.add_to_set(LOCAL_DONAGHY_EVENT_PATHS, event_path)
      local_storage.add_to_set("#{LOCAL_PATH_PREFIX}#{event_path}", ListenerSerializer.dump({queue: queue, class_name: class_name}))
    end
def local_subscribe ( event_path , queue , class_name ) logger . info ( "EventSubscriber: local registering #{event_path} to #{queue}, #{class_name}" ) local_storage . add_to_set ( LOCAL_DONAGHY_EVENT_PATHS , event_path ) local_storage . add_to_set ( "#{LOCAL_PATH_PREFIX}#{event_path}" , ListenerSerializer . dump ( { queue : queue , class_name : class_name } ) ) end
local from code in this process
local from code in this process
event_path
<not_specific>
queue
<not_specific>
class_name
<not_specific>