Skip to content

Commit dcaa8bc

Browse files
committed
Fix duplicated telemetry handler ids
1 parent 4118aca commit dcaa8bc

File tree

1 file changed

+3
-6
lines changed

1 file changed

+3
-6
lines changed

lib/commanded/event_store.ex

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -19,30 +19,27 @@ defmodule OpentelemetryCommanded.EventStore do
1919
read_snapshot
2020
record_snapshot
2121
stream_forward
22-
stream_forward
23-
stream_forward
2422
subscribe
2523
subscribe_to
26-
subscribe_to
2724
unsubscribe
2825
)a
2926
|> Enum.each(fn event ->
3027
:telemetry.attach(
31-
{__MODULE__, :start},
28+
{__MODULE__, event, :start},
3229
[:commanded, :event_store, event, :start],
3330
&__MODULE__.handle_start/4,
3431
[]
3532
)
3633

3734
:telemetry.attach(
38-
{__MODULE__, :stop},
35+
{__MODULE__, event, :stop},
3936
[:commanded, :event_store, event, :stop],
4037
&__MODULE__.handle_stop/4,
4138
[]
4239
)
4340

4441
:telemetry.attach(
45-
{__MODULE__, :exception},
42+
{__MODULE__, event, :exception},
4643
[:commanded, :event_store, event, :exception],
4744
&__MODULE__.handle_exception/4,
4845
[]

0 commit comments

Comments
 (0)