Sha256: e5397719c7b4f634c4a8e26328297e9251411fb17ec1887f9e46b4f7b3c89a95

Contents?: true

Size: 878 Bytes

Versions: 4

Compression:

Stored size: 878 Bytes

Contents

# frozen_string_literal: true

module PgEventstore
  module SubscriptionFeederCommands
    # @!visibility private
    class Base
      include Extensions::OptionsExtension
      include Extensions::BaseCommandExtension

      # @!attribute id
      #   @return [Integer]
      attribute(:id)
      # @!attribute name
      #   @return [String]
      attribute(:name) { self.class.name.split('::').last }
      # @!attribute subscriptions_set_id
      #   @return [Integer]
      attribute(:subscriptions_set_id)
      # @!attribute data
      #   @return [Hash]
      attribute(:data) { {} }
      # @!attribute created_at
      #   @return [Time]
      attribute(:created_at)

      # @param subscription_feeder [PgEventstore::SubscriptionFeeder]
      # @return [void]
      def exec_cmd(subscription_feeder)
        # Implement it in the subclass
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
pg_eventstore-1.1.3 lib/pg_eventstore/subscriptions/subscription_feeder_commands/base.rb
pg_eventstore-1.1.2 lib/pg_eventstore/subscriptions/subscription_feeder_commands/base.rb
pg_eventstore-1.1.1 lib/pg_eventstore/subscriptions/subscription_feeder_commands/base.rb
pg_eventstore-1.1.0 lib/pg_eventstore/subscriptions/subscription_feeder_commands/base.rb