diff options
author | Trygve Laugstøl <trygvis@inamo.no> | 2013-06-16 21:26:17 +0200 |
---|---|---|
committer | Trygve Laugstøl <trygvis@inamo.no> | 2013-06-16 21:26:17 +0200 |
commit | e57f313713ee0fc52d7dd1247c51914d1462dfc2 (patch) | |
tree | f39a49b967f6f18d0637e61f2dd4d8081615283b /src/main/java/io/trygvis/async/JdbcAsyncService.java | |
parent | 1ec4fae12c5e5363591013e5a759590d913d6782 (diff) | |
download | quartz-based-queue-e57f313713ee0fc52d7dd1247c51914d1462dfc2.tar.gz quartz-based-queue-e57f313713ee0fc52d7dd1247c51914d1462dfc2.tar.bz2 quartz-based-queue-e57f313713ee0fc52d7dd1247c51914d1462dfc2.tar.xz quartz-based-queue-e57f313713ee0fc52d7dd1247c51914d1462dfc2.zip |
wip
Diffstat (limited to 'src/main/java/io/trygvis/async/JdbcAsyncService.java')
-rw-r--r-- | src/main/java/io/trygvis/async/JdbcAsyncService.java | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/src/main/java/io/trygvis/async/JdbcAsyncService.java b/src/main/java/io/trygvis/async/JdbcAsyncService.java index fd4b38b..57ab5c6 100644 --- a/src/main/java/io/trygvis/async/JdbcAsyncService.java +++ b/src/main/java/io/trygvis/async/JdbcAsyncService.java @@ -71,12 +71,10 @@ public class JdbcAsyncService { } public Task update(Connection c, Task ref) throws SQLException { - TaskDao taskDao = queueSystem.createTaskDao(c); - - return taskDao.findById(ref.id()); + return queueSystem.createTaskDao(c).findById(ref.id()); } - private QueueController getQueueThread(String name) { + private synchronized QueueController getQueueThread(String name) { QueueController queueController = queues.get(name); if (queueController == null) { |