   def reject(delivery_tag, request, redeliver \\ false) do
     message = MessageManager.remove(delivery_tag)
     unless message == nil do
-      Logger.debug("[Dispatcher] Rejecting message #{delivery_tag}...")
       SubscriptionHandler.reject_rpc(message[:subscription_handler], delivery_tag, ManagerApi.get_api, request, redeliver)
+      Logger.debug("[Dispatcher][Request][#{delivery_tag}] Rejected message")      
+    else
+      Logger.error("[Dispatcher][Request][#{delivery_tag}] Unable to reject message, MessageManager does not have a record!")      
     end
   end
 end
          message: error_msg
        }       
        SystemEvent.create_system_event!(ManagerApi.get_api, event)            
        acknowledge(delivery_tag, request)
      :throw, value -> 
        error_msg = "[Dispatcher] Message #{delivery_tag} Throw called with #{inspect value}"
        Logger.error(error_msg)
        request = %{request | 
          status: :error,
          response_body: %{errors: [error_msg]}

  def acknowledge(delivery_tag, request) do
    message = MessageManager.remove(delivery_tag)
    unless message == nil do
      SubscriptionHandler.acknowledge_rpc(message[:subscription_handler], delivery_tag, ManagerApi.get_api, request)
      Logger.debug("[Dispatcher][Request][#{delivery_tag}] Acknowledged message...")
    else
      Logger.error("[Dispatcher][Request][#{delivery_tag}] Unable to acknowledge message, MessageManager does not have a record!")
    end
  end

