   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}"]},

            case register_queues do
              {:ok, _} -> {:ok, pid}
              {:error, reason} -> 
                Logger.error("Failed to register FleetManager queues:  #{inspect reason}")
                {:ok, pid}
            end       
          else
            {:ok, pid}
          end
        rescue e in _ ->
          Logger.error("An error occurred registering FleetManager queues:  #{inspect e}")
          {:ok, pid}
        end
    end

        }
        acknowledge(delivery_tag, request)
      what, value   -> 
        error_msg = "[Dispatcher] Message #{delivery_tag} Caught #{inspect what} with #{inspect value}"
        Logger.error(error_msg)
        request = %{request | 
          status: :error,
