Sha256: 0076db66cd4de17e24373b3983647ed79261534ab68a9834a053865422643e49
Contents?: true
Size: 1.41 KB
Versions: 12
Compression:
Stored size: 1.41 KB
Contents
# frozen_string_literal: true
module PgEventstore
module CommandHandlers
class SubscriptionFeederCommands
AVAILABLE_COMMANDS = %w[StopAll StartAll].freeze
# @param config_name [Symbol]
# @param subscription_feeder [PgEventstore::SubscriptionFeeder]
def initialize(config_name, subscription_feeder)
@config_name = config_name
@subscription_feeder = subscription_feeder
end
# Look up commands for the given SubscriptionFeeder and execute them
# @return [void]
def process
queries.find_commands(@subscription_feeder.id).each do |command|
unless AVAILABLE_COMMANDS.include?(command[:name])
PgEventstore.logger&.warn(
"#{self.class.name}: Don't know how to handle #{command[:name].inspect}. Details: #{command.inspect}."
)
next
end
send(Utils.underscore_str(command[:name]))
ensure
queries.delete(command[:id])
end
end
private
# @return [PgEventstore::SubscriptionsSetCommandQueries]
def queries
SubscriptionsSetCommandQueries.new(connection)
end
# @return [PgEventstore::Connection]
def connection
PgEventstore.connection(@config_name)
end
def stop_all
@subscription_feeder.stop_all
end
def start_all
@subscription_feeder.start_all
end
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems