diff --git a/mycat2/src/main/java/io/mycat/mysqlclient/VertxMycatConnectionPool.java b/mycat2/src/main/java/io/mycat/mysqlclient/VertxMycatConnectionPool.java index 3654de79d..70d854e38 100644 --- 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 abandonQuery() { public boolean isQuerying() { return !this.queryCloseFuture.isComplete(); } + + @Override + public void onActiveTimestamp(long timestamp) { + this.activeTimeStamp = timestamp; + } + + @Override + public long getActiveTimeStamp() { + return this.activeTimeStamp; + } }