Contents

module Eventboss
  module Listener
    ACTIVE_LISTENERS = {}

    def self.included(base)
      base.extend ClassMethods
    end

    def jid
      @jid ||= SecureRandom.uuid
    end

    attr_reader :postponed_by

    def postpone_by(time_in_secs)
      @postponed_by = time_in_secs.to_i
    end

    module ClassMethods
      def eventboss_options(opts)
        source_app = opts[:source_app] ? "#{opts[:source_app]}-" : ""
        event_name = opts[:event_name]

        ACTIVE_LISTENERS["#{source_app}#{event_name}"] = self
      end
    end
  end
end

Version data entries

13 entries across 13 versions & 1 rubygems

Version	Path
eventboss-1.2.1	lib/eventboss/listener.rb
eventboss-1.2.0	lib/eventboss/listener.rb
eventboss-1.1.3	lib/eventboss/listener.rb
eventboss-1.1.2	lib/eventboss/listener.rb
eventboss-1.1.1	lib/eventboss/listener.rb
eventboss-1.1.0	lib/eventboss/listener.rb
eventboss-1.0.6	lib/eventboss/listener.rb
eventboss-1.0.5	lib/eventboss/listener.rb
eventboss-1.0.4	lib/eventboss/listener.rb
eventboss-1.0.3	lib/eventboss/listener.rb
eventboss-1.0.2	lib/eventboss/listener.rb
eventboss-1.0.1	lib/eventboss/listener.rb
eventboss-1.0.0	lib/eventboss/listener.rb