Sha256: e3027a6d42951cc2e169d3ba3f6c45049cfa6970da0c9c32f19db80f14f13764

Contents?: true

Size: 624 Bytes

Versions: 14

Compression:

Stored size: 624 Bytes

Contents

module Actions
  module Katello
    module EventQueue
      class SuspendedAction
        def initialize(suspended_action)
          @suspended_action = suspended_action
        end

        def notify_queue_item(event_type, object_id, created_at)
          @suspended_action << Monitor::Event[event_type, object_id, created_at]
        end

        def notify_ready
          @suspended_action << Monitor::Ready
        end

        def notify_fatal(error)
          @suspended_action << Monitor::Fatal[error.backtrace && error.backtrace.join('\n'), error.message, error.class.name]
        end
      end
    end
  end
end

Version data entries

14 entries across 14 versions & 1 rubygems

Version Path
katello-3.8.1 app/lib/actions/katello/event_queue/suspended_action.rb
katello-3.7.1.1 app/lib/actions/katello/event_queue/suspended_action.rb
katello-3.7.1 app/lib/actions/katello/event_queue/suspended_action.rb
katello-3.8.0 app/lib/actions/katello/event_queue/suspended_action.rb
katello-3.8.0.rc3 app/lib/actions/katello/event_queue/suspended_action.rb
katello-3.8.0.rc2 app/lib/actions/katello/event_queue/suspended_action.rb
katello-3.7.0 app/lib/actions/katello/event_queue/suspended_action.rb
katello-3.8.0.rc1 app/lib/actions/katello/event_queue/suspended_action.rb
katello-3.7.0.rc2 app/lib/actions/katello/event_queue/suspended_action.rb
katello-3.7.0.rc1 app/lib/actions/katello/event_queue/suspended_action.rb
katello-3.6.0 app/lib/actions/katello/event_queue/suspended_action.rb
katello-3.6.0.1.rc2 app/lib/actions/katello/event_queue/suspended_action.rb
katello-3.6.0.rc2 app/lib/actions/katello/event_queue/suspended_action.rb
katello-3.6.0.rc1 app/lib/actions/katello/event_queue/suspended_action.rb