   def process_request(delivery_tag, payload) do
     request = RpcRequest.from_payload(payload)
     try do
-      Logger.debug("Starting to process request #{delivery_tag}...")
+      Logger.debug("[Dispatcher] Starting to process request #{delivery_tag}...")
       fleet_request = FleetRequest.from_payload(request.request_body)
 
       request = case FleetActions.execute(fleet_request) do
         {:ok, response} ->
+          Logger.debug("[Dispatcher] Request #{delivery_tag} responded successfully:  #{inspect response}")
           %{request | 
             status: :completed,
             response_body: response,
           }
         {:error, reason} ->
+          Logger.debug("[Dispatcher] Request #{delivery_tag} responded failed:  #{inspect reason}")
           %{request | 
             status: :error,
             response_body: %{errors: ["#{inspect reason}"]},

      acknowledge(delivery_tag, request)
    catch
      :exit, code   -> 
        error_msg = "Message #{delivery_tag} Exited with code #{inspect code}"
        Logger.error(error_msg)
        request = %{request | 
          status: :error,

  def start_link do
    case GenServer.start_link(__MODULE__, %{}, name: __MODULE__) do
      {:error, reason} -> 
        Logger.error("[Dispatcher] Failed to start OpenAperture FleetManager:  #{inspect reason}")
        {:error, reason}
      {:ok, pid} ->
        try do
