   def reject(delivery_tag, request, redeliver \\ false) do
     message = MessageManager.remove(delivery_tag)
     unless message == nil do
-      Logger.debug("Rejecting message #{delivery_tag}...")
+      Logger.debug("[Dispatcher] Rejecting message #{delivery_tag}...")
       SubscriptionHandler.reject_rpc(message[:subscription_handler], delivery_tag, ManagerApi.get_api, request, redeliver)
     end
   end

        }
        acknowledge(delivery_tag, request)
      :throw, value -> 
        error_msg = "Message #{delivery_tag} Throw called with #{inspect value}"
        Logger.error(error_msg)
        request = %{request | 
          status: :error,

      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,
