Skip to content

Commit

Permalink
INT-3352 RedisLockRegistry
Browse files Browse the repository at this point in the history
JIRA: https://jira.spring.io/browse/INT-3352

Provid a global lock registry, initially for the correlating
message handlers.

INT-3252 Polishing

- Use a discrete key for each lock and use Redis EXPIRE
- Use an internal DefaultLockRegistry to improve latency
    when threads are using the same registry instance.

INT-3352 More Polish

- Put localLock.unlock() in a finally block.
- Unlock localLock if acquiring the RedisLock fails.

INT-3352 Polishing - PR Comments

- PR Comments
- Improve equals()

INT-3352 Add Aggregator Integration Test

- move lock registry to the `util` package
- Add an aggregator integration test

INT-3352 Add Distributed Aggregator Test

- Simulates a distributed environment with a shared message
    store and distinct lock registries.

INT-3352 More PR Comments

INT-3352 Add Multiple Registry Tests

- Add tests to verify expected behavior when different registries are used.
- Polish javadocs.
  • Loading branch information
garyrussell authored and Artem Bilan committed Apr 6, 2014
1 parent eb0d1dd commit 40a535b
Show file tree
Hide file tree
Showing 8 changed files with 1,193 additions and 2 deletions.
1 change: 1 addition & 0 deletions .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -28,3 +28,4 @@ target
vf.gf.dmn-*
/atlassian-ide-plugin.xml
hostkey.ser
.springBeans
2 changes: 2 additions & 0 deletions build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -96,6 +96,7 @@ subprojects { subproject ->
saajApiVersion = '1.3.5'
saajImplVersion = '1.3.23'
servletApiVersion = '3.1.0'
slf4jVersion = "1.7.6"
smackVersion = '3.2.1'
springAmqpVersion = project.hasProperty('springAmqpVersion') ? project.springAmqpVersion : '1.3.1.RELEASE'
springDataMongoVersion = '1.1.1.RELEASE'
Expand Down Expand Up @@ -453,6 +454,7 @@ project('spring-integration-redis') {
exclude group: 'org.springframework'
}
testCompile "com.lambdaworks:lettuce:$lettuceVersion"
testCompile "org.slf4j:slf4j-log4j12:$slf4jVersion"
}
}

Expand Down
Loading

0 comments on commit 40a535b

Please sign in to comment.