Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INT-2544 Fix FIFO problem with JdbcMessageStore

Browse Source 
Improved polling from Jdbc - INT-2200
To accomplish all that schema change was required so new schemas are commited as well

INT-2544b polished based on Artem's comments

INT-2544b more polishing based on Artem's comments

INT-2544b more polishing based on Artem's comments

INT-2544
defined doPollForMessage(..) method so it could be overriden with custom query to get a single message from the DB

INT-2544
polishing, removed unused import

INT-2544
polishing, added protected getter for JdbcOperations, polished Javadocs

INT-2544 polishing

INT-2544b polishing
added fallback on update when create MessageGroup query fails, fixed the update date

INT-2544b polishing PR comments

INT-2544b polishing white spaces

INT-2544b polsihing white spaces
This commit is contained in:
Oleg Zhurakousky
2012-05-15 14:35:26 -04:00
committed by Gary Russell
parent a1c2c63534
commit 22536d26bf
24 changed files with 385 additions and 243 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
spring-integration-jdbc/src/main/sql/schema.sql.vpp
View File

@@ -7,15 +7,20 @@ CREATE TABLE INT_MESSAGE (
MESSAGE_BYTES ${BLOB}
)#if(${VOODOO}) ${VOODOO}#end;
CREATE TABLE INT_MESSAGE_GROUP (
MESSAGE_ID CHAR(36) NOT NULL,
CREATE INDEX INT_MESSAGE_IX1 ON INT_MESSAGE (CREATED_DATE)#if(${VOODOO}) ${VOODOO}#end;
CREATE TABLE INT_GROUP_TO_MESSAGE (
GROUP_KEY CHAR(36) NOT NULL,
MESSAGE_ID CHAR(36) NOT NULL,
constraint MESSAGE_GROUP_PK primary key (GROUP_KEY, MESSAGE_ID)
)#if(${VOODOO}) ${VOODOO}#end;
CREATE TABLE INT_MESSAGE_GROUP (
GROUP_KEY CHAR(36) NOT NULL PRIMARY KEY,
REGION ${VARCHAR}(100),
MARKED ${BIGINT},
COMPLETE ${BIGINT},
LAST_RELEASED_SEQUENCE ${BIGINT},
CREATED_DATE ${TIMESTAMP} NOT NULL,
UPDATED_DATE ${TIMESTAMP} DEFAULT NULL,
MESSAGE_BYTES ${BLOB},
constraint MESSAGE_GROUP_PK primary key (MESSAGE_ID, GROUP_KEY)
)#if(${VOODOO}) ${VOODOO}#end;
UPDATED_DATE ${TIMESTAMP} DEFAULT NULL
)#if(${VOODOO}) ${VOODOO}#end;