Sha256: 60b136c19adc9f79982e65b0f167f42ff991446a0b3201f71c3dd5c6e7207899
Contents?: true
Size: 596 Bytes
Versions: 88
Compression:
Stored size: 596 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Processing
module Jobs
# Job that runs on each active consumer upon process shutdown (one job per consumer).
class Shutdown < Base
# @param executor [Karafka::Processing::Executor] executor that is suppose to run a given
# job on an active consumer
# @return [Shutdown]
def initialize(executor)
@executor = executor
super()
end
# Runs the shutdown job via an executor.
def call
executor.shutdown
end
end
end
end
end
Version data entries
88 entries across 88 versions & 1 rubygems