diff --git a/activemq-core/src/main/java/org/apache/activemq/store/jdbc/Statements.java b/activemq-core/src/main/java/org/apache/activemq/store/jdbc/Statements.java index 265408c352..131f713191 100755 --- a/activemq-core/src/main/java/org/apache/activemq/store/jdbc/Statements.java +++ b/activemq-core/src/main/java/org/apache/activemq/store/jdbc/Statements.java @@ -311,7 +311,7 @@ public class Statements { public String getLockUpdateStatement() { if (lockUpdateStatement == null) { - lockUpdateStatement = "UPDATE " + getFullLockTableName() + " SET time = ? WHERE ID = 1"; + lockUpdateStatement = "UPDATE " + getFullLockTableName() + " SET TIME = ? WHERE ID = 1"; } return lockUpdateStatement; }