lib/donaghy/event_subscriber.rb
# actually write the listener to the remote storage - usually called from
# an event being handled
actually write the listener to the remote storage - usually called from
an event being handled
actually write the listener to the remote storage - usually called from an event being handled
def global_subscribe(event_path, queue, class_name)
      logger.info("EventSubscriber: global registering #{event_path} to #{queue}, #{class_name}")
      remote_storage.add_to_set(DONAGHY_QUEUES_PATH, queue)
      remote_storage.add_to_set(DONAGHY_EVENT_PATHS, event_path)
      remote_storage.add_to_set("#{PATH_PREFIX}#{event_path}", ListenerSerializer.dump({queue: queue, class_name: class_name}))
      update_local_events
    end
def global_subscribe ( event_path , queue , class_name ) logger . info ( "EventSubscriber: global registering #{event_path} to #{queue}, #{class_name}" ) remote_storage . add_to_set ( DONAGHY_QUEUES_PATH , queue ) remote_storage . add_to_set ( DONAGHY_EVENT_PATHS , event_path ) remote_storage . add_to_set ( "#{PATH_PREFIX}#{event_path}" , ListenerSerializer . dump ( { queue : queue , class_name : class_name } ) ) update_local_events end
actually write the listener to the remote storage - usually called from
an event being handled
actually write the listener to the remote storage - usually called from an event being handled
event_path
<not_specific>
queue
<not_specific>
class_name
<not_specific>