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 774a3ba26e..d73d1f0a36 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 @@ -30,7 +30,7 @@ public class Statements { protected String binaryDataType = "BLOB"; protected String containerNameDataType = "VARCHAR(250)"; protected String msgIdDataType = "VARCHAR(250)"; - protected String sequenceDataType = "INTEGER"; + protected String sequenceDataType = "BIGINT"; protected String longDataType = "BIGINT"; protected String stringIdDataType = "VARCHAR(250)"; protected boolean useExternalMessageReferences; diff --git a/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/AxionJDBCAdapter.java b/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/AxionJDBCAdapter.java index 9341debb77..df751dc091 100755 --- a/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/AxionJDBCAdapter.java +++ b/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/AxionJDBCAdapter.java @@ -56,6 +56,7 @@ public class AxionJDBCAdapter extends StreamJDBCAdapter { statements.setCreateSchemaStatements(createStatements); statements.setDeleteOldMessagesStatement("DELETE FROM " + statements.getFullMessageTableName() + " WHERE ( EXPIRATION<>0 AND EXPIRATION