diff --git a/lib/db-mysql.js b/lib/db-mysql.js
index e46b3c3..a06ce1d 100644
--- a/lib/db-mysql.js
+++ b/lib/db-mysql.js
@@ -15,7 +15,6 @@ const pool = config.mysql ? mysql.createPool({
 }) : null;
 
 exports.pool = pool;
-exports.query = pool.query;
 
 exports.format = (sql, values) => {
     return new Promise((resolve, reject) => {
diff --git a/lib/messages-archive.js b/lib/messages-archive.js
index 97dcde9..eb14de0 100644
--- a/lib/messages-archive.js
+++ b/lib/messages-archive.js
@@ -30,7 +30,7 @@ function insert(params, direction) {
         message: (params.msg || params.message).trim(),
     }];
 
-    db.query(query, values, (err) => {
+    db.pool.query(query, values, (err) => {
         if (err) {
             logger.warn(`MESSAGES-ARCHIVE: DB ERROR on inserting message. ${err.toString()}`);
         }