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

  def acknowledge(delivery_tag, request) do
    message = MessageManager.remove(delivery_tag)
    unless message == nil do
      Logger.debug("Acknowledging message #{delivery_tag}...")
      SubscriptionHandler.acknowledge_rpc(message[:subscription_handler], delivery_tag, ManagerApi.get_api, request)
    end
  end

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