diff --git a/pglablib/ASyncDBConnection.cpp b/pglablib/ASyncDBConnection.cpp
index d661dd6..66bb302 100644
--- a/pglablib/ASyncDBConnection.cpp
+++ b/pglablib/ASyncDBConnection.cpp
@@ -335,7 +335,7 @@ bool ASyncDBConnectionThread::consumeResultInput()
 	bool finished = false;
 	if (m_connection.consumeInput()) {
 		while ( ! finished && ! m_connection.isBusy()) {
-			auto res(m_connection.getResult());
+			auto res(m_connection.getResultNoThrow());
 			{
 				qint64 ms = m_timer.restart();
 				std::lock_guard<std::mutex> lg(m_commandQueue.m_mutex);
@@ -354,7 +354,7 @@ bool ASyncDBConnectionThread::consumeResultInput()
 	}
 	else {
 		// error during consume
-
+		auto error_msg = m_connection.getErrorMessage();
 	}
 	return finished;
 }