diff --git a/lib/postoffice/workers/http.ex b/lib/postoffice/workers/http.ex index 2c5c1afb..cd9827da 100644 --- a/lib/postoffice/workers/http.ex +++ b/lib/postoffice/workers/http.ex @@ -45,14 +45,6 @@ defmodule Postoffice.Workers.Http do target: target ) - {:ok, _data} = - HistoricalData.create_sent_messages(%{ - message_id: message_id, - consumer_id: consumer_id, - payload: historical_payload, - attributes: attributes - }) - historical_pubsub_args = %{ "consumer_id" => consumer_id, "target" => Application.get_env(:postoffice, :pubsub_historical_topic_name), diff --git a/lib/postoffice/workers/pubsub.ex b/lib/postoffice/workers/pubsub.ex index 73f9d456..e2597bad 100644 --- a/lib/postoffice/workers/pubsub.ex +++ b/lib/postoffice/workers/pubsub.ex @@ -40,14 +40,6 @@ defmodule Postoffice.Workers.Pubsub do target: target ) - {:ok, _data} = - HistoricalData.create_sent_messages(%{ - message_id: message_id, - consumer_id: consumer_id, - payload: historical_payload, - attributes: attributes - }) - historical_pubsub_args = %{ "consumer_id" => consumer_id, "target" => Application.get_env(:postoffice, :pubsub_historical_topic_name), diff --git a/test/postoffice/http_worker_test.exs b/test/postoffice/http_worker_test.exs index 425bc793..0be4ad07 100644 --- a/test/postoffice/http_worker_test.exs +++ b/test/postoffice/http_worker_test.exs @@ -91,7 +91,7 @@ defmodule Postoffice.HttpWorkerTest do end) perform_job(HttpWorker, args) - assert Kernel.length(HistoricalData.list_sent_messages()) == 1 + assert Kernel.length(HistoricalData.list_sent_messages()) == 0 end diff --git a/test/postoffice/pubsub_worker_test.exs b/test/postoffice/pubsub_worker_test.exs index c96afb12..c3c78ba7 100644 --- a/test/postoffice/pubsub_worker_test.exs +++ b/test/postoffice/pubsub_worker_test.exs @@ -68,7 +68,7 @@ defmodule Postoffice.PubsubWorkerTest do end) perform_job(PubsubWorker, args) - assert Kernel.length(HistoricalData.list_sent_messages()) == 1 + assert Kernel.length(HistoricalData.list_sent_messages()) == 0 end test "messages can be sent in bulk" do