diff --git a/source/client/src/clientImpl.c b/source/client/src/clientImpl.c
index 471b9b68cb8644925c927c10c2e8392ef2ae2866..179e46527f861185cbb48f5cff11f26db9f78178 100644
--- a/source/client/src/clientImpl.c
+++ b/source/client/src/clientImpl.c
@@ -380,7 +380,7 @@ TAOS_RES* tmq_subscribe(tmq_t* tmq, tmq_list_t* topic_list) {
     char* topicName = topic_list->elems[i];
 
     SName name = {0};
-    char* dbName = getConnectionDB(tmq->pTscObj);
+    char* dbName = getDbOfConnection(tmq->pTscObj);
     tNameSetDbName(&name, tmq->pTscObj->acctId, dbName, strlen(dbName));     
     tNameFromString(&name, topicName, T_NAME_TABLE);