   """
   @spec track(Map) :: term
   def track(%{subscription_handler: subscription_handler, delivery_tag: delivery_tag} = _async_info) do
+    Logger.debug("#{@logprefix} Tracking message #{delivery_tag}...")
     new_message = %{
       process: self(),
       subscription_handler: subscription_handler, 

  """
  @spec remove(String.t()) :: Map
  def remove(delivery_tag) do
    messages = Agent.get(__MODULE__, fn messages -> messages end)
    deleted_message = messages[delivery_tag]
    messages = Map.delete(messages, delivery_tag)
    
    # workload = Enum.reduce Map.keys(messages), [], fn(delivery_tag, workload) ->
    #   workload ++ [%{
    #     description: "Request:  #{delivery_tag}"
    #   }]
    # end
    #Heartbeat.set_workload(workload)

    Agent.update(__MODULE__, fn _ -> messages end)
    deleted_message
  end
end
      start_time: :calendar.universal_time
    }

    Agent.update(__MODULE__, fn messages -> Map.put(messages, delivery_tag, new_message) end)
    
    new_message
  end

