- def handle_info({:send, %{topic: topic} = data, :websub, retries}, state) do
- Logger.debug("RetryQueue: Retrying to send object #{topic}")
+ def handle_cast({:maybe_enqueue, data, transport, retries}, %{dropped: drop_count} = state) do
+ case get_retry_params(retries) do
+ {:retry, timeout} ->
+ Process.send_after(
+ __MODULE__,
+ {:send, data, transport, retries},
+ growth_function(retries)
+ )