diff options
author | Trygve Laugstøl <trygvis@inamo.no> | 2013-06-09 15:15:46 +0200 |
---|---|---|
committer | Trygve Laugstøl <trygvis@inamo.no> | 2013-06-09 15:15:46 +0200 |
commit | 33e3be55dc2d815cbd0208bf59d12a7e727f3105 (patch) | |
tree | a464f750d2cbdd6cdd805e574dd0aa66fa7027fd /src/main/java/io/trygvis/spring/DefaultConfig.java | |
parent | 7465fdb9aa847d29dacc56adbe473f1c1ceb298e (diff) | |
download | quartz-based-queue-33e3be55dc2d815cbd0208bf59d12a7e727f3105.tar.gz quartz-based-queue-33e3be55dc2d815cbd0208bf59d12a7e727f3105.tar.bz2 quartz-based-queue-33e3be55dc2d815cbd0208bf59d12a7e727f3105.tar.xz quartz-based-queue-33e3be55dc2d815cbd0208bf59d12a7e727f3105.zip |
wip
Diffstat (limited to 'src/main/java/io/trygvis/spring/DefaultConfig.java')
-rw-r--r-- | src/main/java/io/trygvis/spring/DefaultConfig.java | 18 |
1 files changed, 14 insertions, 4 deletions
diff --git a/src/main/java/io/trygvis/spring/DefaultConfig.java b/src/main/java/io/trygvis/spring/DefaultConfig.java index 68761f2..3ba28de 100644 --- a/src/main/java/io/trygvis/spring/DefaultConfig.java +++ b/src/main/java/io/trygvis/spring/DefaultConfig.java @@ -1,21 +1,31 @@ package io.trygvis.spring; import io.trygvis.async.AsyncService; +import io.trygvis.async.SqlEffectExecutor; import io.trygvis.queue.QueueService; +import io.trygvis.queue.QueueSystem; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.jdbc.core.JdbcTemplate; +import javax.sql.DataSource; +import java.sql.SQLException; + @Configuration public class DefaultConfig { @Bean - public AsyncService asyncService(JdbcTemplate jdbcTemplate) { - return new SpringJdbcAsyncService(jdbcTemplate); + public QueueSystem queueSystem(DataSource ds) throws SQLException { + return QueueSystem.initialize(new SqlEffectExecutor(ds)); + } + + @Bean + public AsyncService asyncService(QueueSystem queueSystem, JdbcTemplate jdbcTemplate) { + return new SpringJdbcAsyncService(queueSystem, jdbcTemplate); } @Bean - public QueueService queueService(JdbcTemplate jdbcTemplate) { - return new SpringQueueService(jdbcTemplate); + public QueueService queueService(QueueSystem queueSystem, JdbcTemplate jdbcTemplate) { + return new SpringQueueService(queueSystem, jdbcTemplate); } } |