File tree Expand file tree Collapse file tree 7 files changed +12
-12
lines changed
contrib/ruby_event_store-sidekiq_scheduler Expand file tree Collapse file tree 7 files changed +12
-12
lines changed Original file line number Diff line number Diff line change @@ -16,8 +16,8 @@ Declare the scheduler in your Ruby Event Store configuration. We recommend to us
16
16
17
17
``` ruby
18
18
event_store = RailsEventStore ::Client .new (
19
- dispatcher: RailsEventStore ::AfterCommitAsyncDispatcher .new (scheduler: RubyEventStore ::SidekiqScheduler .new (serializer: RubyEventStore ::Serializers ::YAML ),
20
- )
19
+ dispatcher: RailsEventStore ::AfterCommitDispatcher .new (scheduler: RubyEventStore ::SidekiqScheduler .new (serializer: RubyEventStore ::Serializers ::YAML ),
20
+ )
21
21
```
22
22
23
23
Read more about [ using asynchronous handlers] ( https://railseventstore.org/docs/v2/subscribe/#async-handlers )
Original file line number Diff line number Diff line change 4
4
require "rails_event_store"
5
5
6
6
module RubyEventStore
7
- ::RSpec . describe RailsEventStore ::AfterCommitAsyncDispatcher do
7
+ ::RSpec . describe RailsEventStore ::AfterCommitDispatcher do
8
8
around ( :each ) do |example |
9
9
::ActiveRecord ::Base . establish_connection ( adapter : "sqlite3" , database : ":memory:" )
10
10
m =
@@ -28,13 +28,13 @@ class DummyRecord < ::ActiveRecord::Base
28
28
29
29
it_behaves_like :scheduler , SidekiqScheduler . new ( serializer : RubyEventStore ::Serializers ::YAML )
30
30
31
- it_behaves_like :dispatcher , RailsEventStore ::AfterCommitAsyncDispatcher . new ( scheduler : SidekiqScheduler . new ( serializer : RubyEventStore ::Serializers ::YAML ) )
31
+ it_behaves_like :dispatcher , RailsEventStore ::AfterCommitDispatcher . new ( scheduler : SidekiqScheduler . new ( serializer : RubyEventStore ::Serializers ::YAML ) )
32
32
33
33
let ( :event ) { TimeEnrichment . with ( RubyEventStore ::Event . new ( event_id : "83c3187f-84f6-4da7-8206-73af5aca7cc8" ) ) }
34
34
let ( :record ) { RubyEventStore ::Mappers ::Default . new . event_to_record ( event ) }
35
35
let ( :serialized_record ) { record . serialize ( YAML ) . to_h . transform_keys ( &:to_s ) }
36
36
37
- let ( :dispatcher ) { RailsEventStore ::AfterCommitAsyncDispatcher . new ( scheduler : SidekiqScheduler . new ( serializer : RubyEventStore ::Serializers ::YAML ) ) }
37
+ let ( :dispatcher ) { RailsEventStore ::AfterCommitDispatcher . new ( scheduler : SidekiqScheduler . new ( serializer : RubyEventStore ::Serializers ::YAML ) ) }
38
38
39
39
before ( :each ) { TestAsyncHandler . reset }
40
40
Original file line number Diff line number Diff line change 1
1
# frozen_string_literal: true
2
2
3
3
module RailsEventStore
4
- class AfterCommitAsyncDispatcher
4
+ class AfterCommitDispatcher
5
5
def initialize ( scheduler :)
6
6
@scheduler = scheduler
7
7
end
Original file line number Diff line number Diff line change 3
3
require "ruby_event_store"
4
4
require_relative "async_handler_helpers"
5
5
require_relative "link_by_metadata"
6
- require_relative "after_commit_async_dispatcher "
6
+ require_relative "after_commit_dispatcher "
7
7
require_relative "active_job_scheduler"
8
8
require_relative 'active_job_id_only_scheduler'
9
9
require_relative "client"
Original file line number Diff line number Diff line change @@ -9,7 +9,7 @@ def initialize(
9
9
repository : RubyEventStore ::ActiveRecord ::EventRepository . new ( serializer : RubyEventStore ::Serializers ::YAML ) ,
10
10
subscriptions : RubyEventStore ::Subscriptions . new ,
11
11
dispatcher : RubyEventStore ::ComposedDispatcher . new (
12
- RailsEventStore ::AfterCommitAsyncDispatcher . new (
12
+ RailsEventStore ::AfterCommitDispatcher . new (
13
13
scheduler : ActiveJobScheduler . new ( serializer : RubyEventStore ::Serializers ::YAML )
14
14
) ,
15
15
RubyEventStore ::Dispatcher . new
Original file line number Diff line number Diff line change @@ -29,7 +29,7 @@ def initialize(
29
29
repository : RubyEventStore ::ActiveRecord ::EventRepository . new ( serializer : RubyEventStore ::NULL ) ,
30
30
subscriptions : RubyEventStore ::Subscriptions . new ,
31
31
dispatcher : RubyEventStore ::ComposedDispatcher . new (
32
- RailsEventStore ::AfterCommitAsyncDispatcher . new (
32
+ RailsEventStore ::AfterCommitDispatcher . new (
33
33
scheduler : ActiveJobScheduler . new ( serializer : RubyEventStore ::Serializers ::YAML )
34
34
) ,
35
35
RubyEventStore ::Dispatcher . new
Original file line number Diff line number Diff line change 2
2
require "ruby_event_store/spec/dispatcher_lint"
3
3
4
4
module RailsEventStore
5
- ::RSpec . describe AfterCommitAsyncDispatcher do
5
+ ::RSpec . describe AfterCommitDispatcher do
6
6
DummyError = Class . new ( StandardError )
7
7
8
8
class DummyRecord < ActiveRecord ::Base
9
9
self . table_name = "dummy_records"
10
10
after_commit -> { raise DummyError }
11
11
end
12
12
13
- it_behaves_like :dispatcher , AfterCommitAsyncDispatcher . new ( scheduler : ActiveJobScheduler . new ( serializer : RubyEventStore ::Serializers ::YAML ) )
13
+ it_behaves_like :dispatcher , AfterCommitDispatcher . new ( scheduler : ActiveJobScheduler . new ( serializer : RubyEventStore ::Serializers ::YAML ) )
14
14
15
15
let ( :event ) { TimeEnrichment . with ( RubyEventStore ::Event . new ( event_id : "83c3187f-84f6-4da7-8206-73af5aca7cc8" ) ) }
16
16
let ( :record ) { RubyEventStore ::Mappers ::Default . new . event_to_record ( event ) }
17
17
let ( :serialized_record ) { record . serialize ( RubyEventStore ::Serializers ::YAML ) . to_h . transform_keys ( &:to_s ) }
18
18
19
- let ( :dispatcher ) { AfterCommitAsyncDispatcher . new ( scheduler : ActiveJobScheduler . new ( serializer : RubyEventStore ::Serializers ::YAML ) ) }
19
+ let ( :dispatcher ) { AfterCommitDispatcher . new ( scheduler : ActiveJobScheduler . new ( serializer : RubyEventStore ::Serializers ::YAML ) ) }
20
20
21
21
before ( :each ) { MyActiveJobAsyncHandler . reset }
22
22
You can’t perform that action at this time.
0 commit comments