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

INT-1464: Check priority channel registration

Browse Source
This commit is contained in:
Dave Syer
2010-11-09 10:43:46 +00:00
parent 222cd88bac
commit bd1373ecff
3 changed files with 90 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-integration-core/src/test/java/org/springframework/integration/aggregator/CorrelatingMessageBarrierTests.java
View File

@@ -122,10 +122,10 @@ public class CorrelatingMessageBarrierTests {
private final ConcurrentMap<Object, Semaphore> keyLocks = new ConcurrentHashMap<Object, Semaphore>();
public boolean canRelease(MessageGroup messageGroup) {
System.out.println("Trying to release group: " + messageGroup + "\n to thread: " + Thread.currentThread());
// System.out.println("Trying to release group: " + messageGroup + "\n to thread: " + Thread.currentThread());
Object correlationKey = messageGroup.getGroupId();
Semaphore lock = lockForKey(correlationKey);
System.out.println(Thread.currentThread() + " got lock: " + lock);
// System.out.println(Thread.currentThread() + " got lock: " + lock);
return lock.tryAcquire();
}