Skip to content

Commit

Permalink
Merge branch 'rabbitMQ_version_upgrade' into staging
Browse files Browse the repository at this point in the history
  • Loading branch information
zephyranthes03 committed Feb 14, 2025
2 parents 634de8c + 5c4dc4f commit 01577c0
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 15 deletions.
2 changes: 1 addition & 1 deletion config/config.exs
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ config :bullhorn,

config :logger, :console,
format: "$time $metadata[$level] $message\n",
metadata: [:request_id, :user_id, :order_id, :trace_id, :span_id, :message],
metadata: [:request_id, :user_id, :order_id, :trace_id, :span_id],
level: :info

config :logger_json, :backend,
Expand Down
17 changes: 3 additions & 14 deletions lib/bullhorn/broadway.ex
Original file line number Diff line number Diff line change
Expand Up @@ -60,20 +60,9 @@ defmodule Bullhorn.Broadway do
message: inspect(failed_message)
)

Appsignal.send_error(
%RuntimeError{},
"Failed Broadway Message",
%{data: failed_message.data}
)
span = Appsignal.Tracer.current_span()

if span do
Appsignal.Span.set_sample_data(span, "message", %{data: failed_message.data})
end

# Appsignal.send_error(%RuntimeError{}, "Failed Broadway Message", [], %{}, nil, fn transaction ->
# Appsignal.Transaction.set_sample_data(transaction, "message", %{data: failed_message.data})
# end)
Appsignal.send_error(%RuntimeError{}, "Failed Broadway Message", [], %{}, nil, fn transaction ->
Appsignal.Transaction.set_sample_data(transaction, "message", %{data: failed_message.data})
end)

[failed_message]
end
Expand Down

0 comments on commit 01577c0

Please sign in to comment.