yoho-search / yoho-search-consumer · Commits

Go to a project

Authored by hugufei
Commit 424fb19e8cd785290c2c76982a833328e1e0be09 1 parent 8f9c6efa

修复DataVersionKey

Inline Side-by-side
Showing 1 changed file with 1 additions and 1 deletions
@@ -85,7 +85,7 @@ public abstract class AbstractMqListener implements ApplicationEventPublisherAwa @@ -85,7 +85,7 @@ public abstract class AbstractMqListener implements ApplicationEventPublisherAwa
85 String dbName = searchMqMessage.getDbName(); 85 String dbName = searchMqMessage.getDbName();
86 String tableName = searchMqMessage.getTableName(); 86 String tableName = searchMqMessage.getTableName();
87 String primaryKeysValue = searchMessageHelper.getPrimaryKeysValue(searchMqMessage.getDbName(), tableName, searchMqMessage.getData()); 87 String primaryKeysValue = searchMessageHelper.getPrimaryKeysValue(searchMqMessage.getDbName(), tableName, searchMqMessage.getData());
88 - return new StringBuilder(dbName).append("_").append(tableName).append("_").append("_").append(primaryKeysValue).toString(); 88 + return new StringBuilder(dbName).append(".").append(tableName).append(".").append(primaryKeysValue).toString();
89 } 89 }
90 90
91 private boolean checkDataVersion(SearchMqMessage searchMqMessage) { 91 private boolean checkDataVersion(SearchMqMessage searchMqMessage) {