diff --git a/.github/workflows/release.yml b/.github/workflows/release.yml
index f1d5b7b..2ba1e7f 100644
--- a/.github/workflows/release.yml
+++ b/.github/workflows/release.yml
@@ -18,7 +18,7 @@ jobs:
           fetch-depth: 0 # Fetch current tag as annotated. See https://github.com/actions/checkout/issues/290
       - uses: ruby/setup-ruby@v1
         with:
-          ruby-version: 3.2
+          ruby-version: 3.4
       - name: Configure RubyGems Credentials
         uses: rubygems/configure-rubygems-credentials@main
       - name: Publish to RubyGems
diff --git a/.github/workflows/rspec.yml b/.github/workflows/rspec.yml
index a8045e1..e6ff118 100644
--- a/.github/workflows/rspec.yml
+++ b/.github/workflows/rspec.yml
@@ -17,23 +17,21 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        ruby: ["3.2"]
+        ruby: ["3.4"]
         gemfile: [
-          "gemfiles/rails71.gemfile",
+          "gemfiles/rails8.gemfile",
         ]
         include:
         - ruby: "3.4"
           gemfile: "gemfiles/railsmaster.gemfile"
         - ruby: "3.3"
           gemfile: "gemfiles/rails8.gemfile"
-        - ruby: "3.1"
+        - ruby: "3.2"
           gemfile: "gemfiles/rails7.gemfile"
-        - ruby: "3.0"
+        - ruby: "3.1"
           gemfile: "gemfiles/rails7.gemfile"
-        - ruby: "2.7"
-          gemfile: "gemfiles/rails6.gemfile"
     steps:
-    - uses: actions/checkout@v2
+    - uses: actions/checkout@v4
     - name: Install system deps
       run: |
         sudo apt-get update
diff --git a/.rubocop-md.yml b/.rubocop-md.yml
index ea3f1d1..aa5be96 100644
--- a/.rubocop-md.yml
+++ b/.rubocop-md.yml
@@ -9,4 +9,8 @@ AllCops:
 
 Naming/FileName:
   Exclude:
-   - '**/*.md'
+    - '**/*.md'
+
+Lint/ConstantReassignment:
+  Exclude:
+    - '**/*.md'
diff --git a/.rubocop.yml b/.rubocop.yml
index 80d2011..da3ed21 100644
--- a/.rubocop.yml
+++ b/.rubocop.yml
@@ -17,6 +17,7 @@ AllCops:
   DisplayCopNames: true
   SuggestExtensions: false
   NewCops: disable
+  TargetRubyVersion: 3.1
 
 Standard/BlockSingleLineBraces:
   Enabled: false
diff --git a/CHANGELOG.md b/CHANGELOG.md
index e683135..c218ff1 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -2,6 +2,8 @@
 
 ## master
 
+- Added `Downstream::Event.define` to use Data-backed event payloads.
+
 ## 1.6.0 (2025-02-14)
 
 - Reset subscribers on code reloading to avoid double execution.
diff --git a/README.md b/README.md
index 0185b03..97754ba 100644
--- a/README.md
+++ b/README.md
@@ -59,6 +59,22 @@ Each event has predefined (_reserved_) fields:
 
 Events are stored in `app/events` folder.
 
+You can also define events using the Data-interface:
+
+```ruby
+ProfileCreated = Downstream::Event.define(:user)
+
+# or with an explicit identifier
+ProfileCreated = Downstream::Event.define(:user) do
+  self.identifier = "user.profile_created"
+end
+```
+
+Date-events provide the same interface as regular events but use Data classes for keeping event payloads (`event.data`) and are frozen (as well as their derivatives, such as `event.to_h`).
+
+> [!NOTE]
+> Data-events are only available in Ruby 3.2+.
+
 ### Publish events
 
 To publish an event you must first create an instance of the event class and call `Downstream.publish` method:
diff --git a/downstream.gemspec b/downstream.gemspec
index 9479157..20243c1 100644
--- a/downstream.gemspec
+++ b/downstream.gemspec
@@ -29,11 +29,11 @@ Gem::Specification.new do |spec|
 
   spec.files = Dir.glob("lib/**/*") + %w[LICENSE.txt README.md]
   spec.require_paths = ["lib"]
-  spec.required_ruby_version = ">= 2.7"
+  spec.required_ruby_version = ">= 3.1"
 
   spec.add_dependency "after_commit_everywhere", "~> 1.0"
   spec.add_dependency "globalid", "~> 1.0"
-  spec.add_dependency "rails", ">= 6"
+  spec.add_dependency "rails", ">= 7"
 
   spec.add_development_dependency "bundler", ">= 1.16"
   spec.add_development_dependency "combustion", "~> 1.3"
diff --git a/gemfiles/rails6.gemfile b/gemfiles/rails6.gemfile
deleted file mode 100644
index 39c8998..0000000
--- a/gemfiles/rails6.gemfile
+++ /dev/null
@@ -1,6 +0,0 @@
-source 'https://rubygems.org'
-
-gem 'sqlite3', '~> 1.4.0'
-gem 'rails', '~> 6.0'
-
-gemspec path: '..'
diff --git a/gemfiles/resmaster.gemfile b/gemfiles/resmaster.gemfile
index 2ae567e..3bc8b4b 100644
--- a/gemfiles/resmaster.gemfile
+++ b/gemfiles/resmaster.gemfile
@@ -1,7 +1,7 @@
 source 'https://rubygems.org'
 
-gem 'sqlite3', '~> 1.4'
-gem 'rails', '~> 7.0'
+gem 'sqlite3', '~> 2.0'
+gem 'rails', '~> 8.0'
 gem 'rails_event_store', github: 'RailsEventStore/rails_event_store'
 
 gemspec path: '..'
diff --git a/lib/downstream.rb b/lib/downstream.rb
index cb9c5bc..60f5d0b 100644
--- a/lib/downstream.rb
+++ b/lib/downstream.rb
@@ -8,6 +8,8 @@
 
 require "downstream/config"
 require "downstream/event"
+require "downstream/data_event"
+require "downstream/subscriber"
 require "downstream/pubsub_adapters/abstract_pubsub"
 require "downstream/subscriber_job"
 
@@ -27,18 +29,26 @@ def subscribe(subscriber = nil, to: nil, async: false, &block)
       subscriber ||= block if block
       raise ArgumentError, "Subsriber must be present" if subscriber.nil?
 
-      identifier = construct_identifier(subscriber, to)
+      construct_identifiers(subscriber, to).map do
+        pubsub.subscribe(_1, subscriber, async: async)
+      end.then do
+        next _1.first if _1.size == 1
 
-      pubsub.subscribe(identifier, subscriber, async: async)
+        _1
+      end
     end
 
     # temporary subscriptions
     def subscribed(subscriber, to: nil, &block)
       raise ArgumentError, "Subsriber must be present" if subscriber.nil?
 
-      identifier = construct_identifier(subscriber, to)
+      construct_identifiers(subscriber, to).map do
+        pubsub.subscribed(_1, subscriber, &block)
+      end.then do
+        next _1.first if _1.size == 1
 
-      pubsub.subscribed(identifier, subscriber, &block)
+        _1
+      end
     end
 
     def publish(event)
@@ -47,28 +57,34 @@ def publish(event)
 
     private
 
-    def construct_identifier(subscriber, to)
-      to ||= infer_event_from_subscriber(subscriber) if subscriber.is_a?(Module)
+    def construct_identifiers(subscriber, to)
+      to ||= infer_events_from_subscriber(subscriber) if subscriber.is_a?(Module)
 
       if to.nil?
         raise ArgumentError, "Couldn't infer event from subscriber. " \
                               "Please, specify event using `to:` option"
       end
 
-      identifier = if to.is_a?(Class) && Event >= to # rubocop:disable Style/YodaCondition
-        to.identifier
-      else
-        to
-      end
+      Array(to).map do
+        identifier = if _1.is_a?(Class) && Event >= _1 # rubocop:disable Style/YodaCondition
+          _1.identifier
+        else
+          _1
+        end
 
-      "#{config.namespace}.#{identifier}"
+        "#{config.namespace}.#{identifier}"
+      end
     end
 
-    def infer_event_from_subscriber(subscriber)
+    def infer_events_from_subscriber(subscriber)
+      if subscriber.is_a?(Class) && Subscriber >= subscriber # rubocop:disable Style/YodaCondition
+        return subscriber.event_names
+      end
+
       event_class_name = subscriber.name.split("::").yield_self do |parts|
         # handle explicti top-level name, e.g. ::Some::Event
         parts.shift if parts.first.empty?
-        # drop last part – it's a unique subscriber name
+        # drop last part—it's a unique subscriber name
         parts.pop
 
         parts.last.sub!(/^On/, "")
diff --git a/lib/downstream/data_event.rb b/lib/downstream/data_event.rb
new file mode 100644
index 0000000..5717c48
--- /dev/null
+++ b/lib/downstream/data_event.rb
@@ -0,0 +1,32 @@
+# frozen_string_literal: true
+
+module Downstream
+  class DataEvent < Event
+    class << self
+      attr_writer :data_class
+
+      def data_class
+        return @data_class if @data_class
+
+        @data_class = superclass.data_class
+      end
+
+      undef_method :attributes
+      undef_method :defined_attributes
+    end
+
+    def initialize(event_id: nil, **attrs)
+      @event_id = event_id || SecureRandom.hex(10)
+      @data = self.class.data_class.new(**attrs)
+      freeze
+    end
+
+    def to_h
+      {
+        type:,
+        event_id:,
+        data: data.to_h.freeze
+      }.freeze
+    end
+  end
+end
diff --git a/lib/downstream/engine.rb b/lib/downstream/engine.rb
index aaf8ac0..3e85b42 100644
--- a/lib/downstream/engine.rb
+++ b/lib/downstream/engine.rb
@@ -6,6 +6,19 @@ module Downstream
   class Engine < ::Rails::Engine
     config.downstream = Downstream.config
 
+    ::GlobalID::Locator.use "downstream" do |gid|
+      params = gid.params.each_with_object({}) do |(key, value), memo|
+        memo[key.to_sym] = if value.is_a?(String) && value.start_with?("gid://")
+          GlobalID::Locator.locate(value)
+        else
+          value
+        end
+      end
+
+      gid.model_name.constantize
+        .new(event_id: gid.model_id, **params)
+    end
+
     config.to_prepare do
       Downstream.pubsub.reset
       ActiveSupport.run_load_hooks("downstream-events", Downstream)
diff --git a/lib/downstream/event.rb b/lib/downstream/event.rb
index c7fc028..d088f2b 100644
--- a/lib/downstream/event.rb
+++ b/lib/downstream/event.rb
@@ -1,18 +1,5 @@
 # frozen_string_literal: true
 
-GlobalID::Locator.use "downstream" do |gid|
-  params = gid.params.each_with_object({}) do |(key, value), memo|
-    memo[key.to_sym] = if value.is_a?(String) && value.start_with?("gid://")
-      GlobalID::Locator.locate(value)
-    else
-      value
-    end
-  end
-
-  gid.model_name.constantize
-    .new(event_id: gid.model_id, **params)
-end
-
 module Downstream
   class Event
     extend ActiveModel::Naming
@@ -26,7 +13,7 @@ class << self
       def identifier
         return @identifier if instance_variable_defined?(:@identifier)
 
-        @identifier = name.underscore.tr("/", ".")
+        @identifier = name.underscore.tr("/", ".").gsub(/_event$/, "")
       end
 
       # define store readers
@@ -56,6 +43,20 @@ def defined_attributes
           end
       end
 
+      def define(*fields, &)
+        fields.each do |field|
+          raise ArgumentError, "#{field} is reserved" if RESERVED_ATTRIBUTES.include?(field)
+        end
+
+        data_class = ::Data.define(*fields)
+
+        Class.new(DataEvent, &).tap do
+          _1.data_class = data_class
+
+          _1.delegate(*fields, to: :data)
+        end
+      end
+
       def i18n_scope
         :activemodel
       end
@@ -94,7 +95,7 @@ def to_h
     end
 
     def to_global_id
-      new_data = data.each_with_object({}) do |(key, value), memo|
+      new_data = data.to_h.each_with_object({}) do |(key, value), memo|
         memo[key] = if value.respond_to?(:to_global_id)
           value.to_global_id
         else
diff --git a/lib/downstream/rspec/have_published_event.rb b/lib/downstream/rspec/have_published_event.rb
index 7cc8e78..1369779 100644
--- a/lib/downstream/rspec/have_published_event.rb
+++ b/lib/downstream/rspec/have_published_event.rb
@@ -74,7 +74,7 @@ def matches?(block)
     end
 
     def failure_message
-      (+"expected to publish #{event_class.identifier} event").tap do |msg|
+      "expected to publish #{event_class.identifier} event".tap do |msg|
         msg << " #{message_expectation_modifier}, but haven't published"
       end
     end
diff --git a/lib/downstream/subscriber.rb b/lib/downstream/subscriber.rb
new file mode 100644
index 0000000..82e1635
--- /dev/null
+++ b/lib/downstream/subscriber.rb
@@ -0,0 +1,32 @@
+# frozen_string_literal: true
+
+module Downstream
+  class Subscriber
+    class << self
+      # All public names are considered event handlers
+      # (same concept as action_names in controllers/mailers)
+      def event_names
+        @event_names ||= begin
+          # All public instance methods of this class, including ancestors
+          methods = (public_instance_methods(true) -
+            # Except for public instance methods of Base and its ancestors
+            Downstream.public_instance_methods(true) +
+            # Be sure to include shadowed public instance methods of this class
+            public_instance_methods(false)).uniq.map(&:to_s)
+          methods.to_set
+        end
+      end
+
+      # Downstream subscriber interface
+      def call(event)
+        new.process_event(event)
+      end
+    end
+
+    def process_event(event)
+      # TODO: callbacks? instrumentation?
+      # TODO: namespaced events?
+      public_send(event.type, event)
+    end
+  end
+end
diff --git a/spec/lib/data_event_spec.rb b/spec/lib/data_event_spec.rb
new file mode 100644
index 0000000..15f8d54
--- /dev/null
+++ b/spec/lib/data_event_spec.rb
@@ -0,0 +1,83 @@
+# frozen_string_literal: true
+
+require "spec_helper"
+
+describe Downstream::Event, skip: !defined?(Data) do
+  let(:event_class) do
+    described_class.define(:user_id, :action_type) do
+      self.identifier = "test_event"
+    end
+  end
+
+  let(:event) { event_class.new(user_id: 1, action_type: "test") }
+
+  specify do
+    expect(event).to be_frozen
+    expect(event.data).to be_a(Data)
+
+    expect(event.user_id).to eq 1
+    expect(event.action_type).to eq "test"
+
+    expect(event.data.user_id).to eq 1
+    expect(event.data.action_type).to eq "test"
+
+    expect(event.event_id).not_to be_nil
+  end
+
+  describe ".identifier" do
+    specify "explicit" do
+      expect(event_class.identifier).to eq "test_event"
+    end
+
+    specify "inferred" do
+      stub_const("Downstream::DataTestEvent", Downstream::Event.define(:user_id))
+      expect(Downstream::DataTestEvent.identifier).to eq "downstream.data_test"
+    end
+  end
+
+  describe "#to_h" do
+    specify do
+      hevent = event.to_h
+      expect(hevent).to eq(
+        event_id: event.event_id,
+        data: {
+          user_id: 1,
+          action_type: "test"
+        },
+        type: "test_event"
+      )
+      expect(hevent).to be_frozen
+      expect(hevent[:data]).to be_frozen
+    end
+  end
+
+  specify "sets event_id if event_id is provided" do
+    event = event_class.new(event_id: "123", user_id: 22, action_type: "test")
+    expect(event.to_h).to eq(
+      event_id: "123",
+      data: {
+        user_id: 22,
+        action_type: "test"
+      },
+      type: "test_event"
+    )
+  end
+
+  specify "raises if unknown field is passed" do
+    expect { event_class.new(users_ids: [1]) }.to raise_error(
+      ArgumentError, /missing keywords: :user_id, :action_type/
+    )
+  end
+
+  specify "raises argument error if type attribute is defined" do
+    expect { described_class.define(:type) }.to raise_error(
+      ArgumentError, /type is reserved/
+    )
+  end
+
+  specify "raises argument error if event_id attribute is defined" do
+    expect { described_class.define(:event_id) }.to raise_error(
+      ArgumentError, /event_id is reserved/
+    )
+  end
+end
diff --git a/spec/lib/event_spec.rb b/spec/lib/event_spec.rb
index 29dfb56..418d188 100644
--- a/spec/lib/event_spec.rb
+++ b/spec/lib/event_spec.rb
@@ -19,7 +19,7 @@
     end
 
     specify "inferred" do
-      expect(Downstream::AnotherTestEvent.identifier).to eq "downstream.another_test_event"
+      expect(Downstream::AnotherTestEvent.identifier).to eq "downstream.another_test"
     end
   end
 
diff --git a/spec/lib/rspec_matchers_spec.rb b/spec/lib/rspec_matchers_spec.rb
index 342e49d..8532340 100644
--- a/spec/lib/rspec_matchers_spec.rb
+++ b/spec/lib/rspec_matchers_spec.rb
@@ -44,7 +44,7 @@
         expect do
           expect { Downstream.publish event }
             .to have_published_event(Downstream::AnotherTestEvent)
-        end.to raise_error(/to publish downstream.another_test_event.+exactly once, but/)
+        end.to raise_error(/to publish downstream.another_test.+exactly once, but/)
       end
 
       specify "attributes don't match" do
diff --git a/spec/lib/subscriptions_spec.rb b/spec/lib/subscriptions_spec.rb
index e92b1e5..8fcc340 100644
--- a/spec/lib/subscriptions_spec.rb
+++ b/spec/lib/subscriptions_spec.rb
@@ -16,6 +16,18 @@ def call(event)
   end
 end
 
+class TestSubscriber < Downstream::Subscriber
+  class << self
+    def events
+      @events ||= []
+    end
+  end
+
+  def test_event(event) = self.class.events << event
+
+  alias_method :another_test, :test_event
+end
+
 describe "sync #subscribe" do
   let(:event_class) { Downstream::TestEvent }
 
@@ -77,6 +89,27 @@ def call(event)
     end
   end
 
+  it "subscribes with a subscriber", skip: !defined?(::Data) do
+    Downstream.subscribe(TestSubscriber)
+
+    event = event_class.new(user_id: 0)
+
+    Downstream.publish event
+
+    expect(TestSubscriber.events.size).to eq 1
+    expect(TestSubscriber.events.last).to eq event
+
+    another_event_class = ::Downstream::Event.define(:user_id, :action_type) do
+      self.identifier = "another_test"
+    end
+
+    event2 = another_event_class.new(user_id: 42, action_type: "leave")
+    Downstream.publish event2
+
+    expect(TestSubscriber.events.size).to eq 2
+    expect(TestSubscriber.events.last).to eq event2
+  end
+
   it "temporary subscribes" do
     event = event_class.new(user_id: 0)
 
diff --git a/spec/spec_helper.rb b/spec/spec_helper.rb
index 1957429..c72ffda 100644
--- a/spec/spec_helper.rb
+++ b/spec/spec_helper.rb
@@ -40,6 +40,7 @@
   config.run_all_when_everything_filtered = true
 
   config.after(:each) do
+    Downstream.pubsub.reset
     # Clear ActiveJob jobs
     ActiveJob::Base.queue_adapter.enqueued_jobs.clear
     ActiveJob::Base.queue_adapter.performed_jobs.clear