Sha256: a30ce16b7c1f6b8bb25c0f397cba48617e2b73255677295e042112f0639e8d83
Contents?: true
Size: 593 Bytes
Versions: 30
Compression:
Stored size: 593 Bytes
Contents
module Actions
module Katello
module EventQueue
class SuspendedAction
def initialize(suspended_action)
@suspended_action = suspended_action
end
def notify_count(processed_count)
@suspended_action << Monitor::Count[processed_count, Time.now]
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
30 entries across 30 versions & 1 rubygems