fix io.mycat.mysqlclient.VertxMycatConnectionPool

MyCATApache · Jun 6, 2022 · 5cf392b · 5cf392b
1 parent 95c99e7
commit 5cf392b
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/mycat2/src/main/java/io/mycat/mysqlclient/VertxMycatConnectionPool.java b/mycat2/src/main/java/io/mycat/mysqlclient/VertxMycatConnectionPool.java
@@ -53,6 +53,8 @@ public class VertxMycatConnectionPool implements NewMycatConnection {
 
     private boolean close = false;
 
+    private long activeTimeStamp;
+
     public VertxMycatConnectionPool(String targetName, VertxConnection connection, VertxPoolConnectionImpl vertxConnectionPool) {
         this.targetName = targetName;
         this.connection = connection;
@@ -289,4 +291,14 @@ public synchronized Future<Void> abandonQuery() {
     public boolean isQuerying() {
         return !this.queryCloseFuture.isComplete();
     }
+
+    @Override
+    public void onActiveTimestamp(long timestamp) {
+        this.activeTimeStamp = timestamp;
+    }
+
+    @Override
+    public long getActiveTimeStamp() {
+        return this.activeTimeStamp;
+    }
 }