Author: chirino
Date: Wed Feb 15 08:08:24 2006
New Revision: 378025
URL: http://svn.apache.org/viewcvs?rev=378025&view=rev
Log:
http://jira.activemq.org/jira/browse/AMQ-565
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/AxionJDBCAdapter.java
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultStatementProvider.java
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/AxionJDBCAdapter.java
URL:
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/AxionJDBCAdapter.java?rev=378025&r1=378024&r2=378025&view=diff
==============================================================================
---
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/AxionJDBCAdapter.java
(original)
+++
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/AxionJDBCAdapter.java
Wed Feb 15 08:08:24 2006
@@ -43,6 +43,7 @@
+", PRIMARY KEY ( ID ) )",
"CREATE INDEX "+getTablePrefix()+messageTableName+"_MIDX
ON "+getTablePrefix()+messageTableName+" (MSGID_PROD,MSGID_SEQ)",
"CREATE INDEX "+getTablePrefix()+messageTableName+"_CIDX
ON "+getTablePrefix()+messageTableName+" (CONTAINER)",
+ "CREATE INDEX "+getFullMessageTableName()+"_EIDX ON
"+getFullMessageTableName()+" (EXPIRATION)",
"CREATE TABLE
"+getTablePrefix()+durableSubAcksTableName+"("
+"CONTAINER "+containerNameDataType+" NOT NULL"
+", CLIENT_ID "+stringIdDataType+" NOT NULL"
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultStatementProvider.java
URL:
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultStatementProvider.java?rev=378025&r1=378024&r2=378025&view=diff
==============================================================================
---
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultStatementProvider.java
(original)
+++
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultStatementProvider.java
Wed Feb 15 08:08:24 2006
@@ -50,7 +50,8 @@
+", MSG "+(useExternalMessageReferences ?
stringIdDataType : binaryDataType)
+", PRIMARY KEY ( ID ) )",
"CREATE INDEX "+getFullMessageTableName()+"_MIDX ON
"+getFullMessageTableName()+" (MSGID_PROD,MSGID_SEQ)",
- "CREATE INDEX "+getFullMessageTableName()+"_CIDX ON
"+getFullMessageTableName()+" (CONTAINER)",
+ "CREATE INDEX "+getFullMessageTableName()+"_CIDX ON
"+getFullMessageTableName()+" (CONTAINER)",
+ "CREATE INDEX "+getFullMessageTableName()+"_EIDX ON
"+getFullMessageTableName()+" (EXPIRATION)",
"CREATE TABLE "+getTablePrefix()+durableSubAcksTableName+"("
+"CONTAINER "+containerNameDataType+" NOT NULL"
+", CLIENT_ID "+stringIdDataType+" NOT NULL"
