Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

AMQ-6602 - Removing lambdas for java 7 compatibility

This commit is contained in:
Christopher L. Shannon (cshannon) 2017-02-23 10:55:20 -05:00
parent 79069598b1
commit 1f53b124bc
1 changed files with 17 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
activemq-client/src/test/java/org/apache/activemq/thread/TaskRunnerFactoryTest.java
View File

@ -46,14 +46,24 @@ public class TaskRunnerFactoryTest {
final List<TaskRunner> runners = Collections.synchronizedList(new ArrayList<>(10)); final List<TaskRunner> runners = Collections.synchronizedList(new ArrayList<>(10));
for (int i = 0; i < 10; i++) { for (int i = 0; i < 10; i++) {
service.execute(() -> { service.execute(new Runnable() {
try {
latch1.await(); @Override
} catch (InterruptedException e) { public void run() {
throw new IllegalStateException(e); try {
latch1.await();
} catch (InterruptedException e) {
throw new IllegalStateException(e);
}
runners.add(factory.createTaskRunner(new Task() {
@Override
public boolean iterate() {
return false;
}
}, "task"));
latch2.countDown();
} }
runners.add(factory.createTaskRunner(() -> true, "task") );
latch2.countDown();
}); });
} }