diff --git a/grails-jesque/grails-app/services/grails/plugin/jesque/JesqueConfigurationService.groovy b/grails-jesque/grails-app/services/grails/plugin/jesque/JesqueConfigurationService.groovy index 95583a0..511cfc0 100644 --- a/grails-jesque/grails-app/services/grails/plugin/jesque/JesqueConfigurationService.groovy +++ b/grails-jesque/grails-app/services/grails/plugin/jesque/JesqueConfigurationService.groovy @@ -3,6 +3,9 @@ package grails.plugin.jesque import org.joda.time.DateTimeZone class JesqueConfigurationService { + + static transactional = false + def grailsApplication def jesqueSchedulerService diff --git a/grails-jesque/grails-app/services/grails/plugin/jesque/JesqueDelayedJobThreadService.groovy b/grails-jesque/grails-app/services/grails/plugin/jesque/JesqueDelayedJobThreadService.groovy index c4d25a0..640463e 100644 --- a/grails-jesque/grails-app/services/grails/plugin/jesque/JesqueDelayedJobThreadService.groovy +++ b/grails-jesque/grails-app/services/grails/plugin/jesque/JesqueDelayedJobThreadService.groovy @@ -6,8 +6,8 @@ import java.util.concurrent.atomic.AtomicReference import org.joda.time.DateTime class JesqueDelayedJobThreadService implements Runnable, DisposableBean { - static transactional = true - static scope = 'singleton' + + static transactional = false protected static final Integer IDLE_WAIT_TIME = 10 * 1000 protected AtomicReference threadState = new AtomicReference(JesqueDelayedJobThreadState.New) diff --git a/grails-jesque/grails-app/services/grails/plugin/jesque/JesqueSchedulerService.groovy b/grails-jesque/grails-app/services/grails/plugin/jesque/JesqueSchedulerService.groovy index 64b3d57..3034b36 100644 --- a/grails-jesque/grails-app/services/grails/plugin/jesque/JesqueSchedulerService.groovy +++ b/grails-jesque/grails-app/services/grails/plugin/jesque/JesqueSchedulerService.groovy @@ -10,6 +10,7 @@ import org.joda.time.Seconds import org.joda.time.DateTimeZone class JesqueSchedulerService { + static transactional = false def redisService diff --git a/grails-jesque/grails-app/services/grails/plugin/jesque/JesqueSchedulerThreadService.groovy b/grails-jesque/grails-app/services/grails/plugin/jesque/JesqueSchedulerThreadService.groovy index 4df8766..e8579f3 100644 --- a/grails-jesque/grails-app/services/grails/plugin/jesque/JesqueSchedulerThreadService.groovy +++ b/grails-jesque/grails-app/services/grails/plugin/jesque/JesqueSchedulerThreadService.groovy @@ -7,8 +7,7 @@ import java.util.concurrent.atomic.AtomicReference class JesqueSchedulerThreadService implements Runnable, DisposableBean { - static transactional = true - static scope = 'singleton' + static transactional = false protected static String hostName protected static final Integer IDLE_WAIT_TIME = 10 * 1000 diff --git a/grails-jesque/grails-app/services/grails/plugin/jesque/JesqueService.groovy b/grails-jesque/grails-app/services/grails/plugin/jesque/JesqueService.groovy index fc914c7..8651129 100644 --- a/grails-jesque/grails-app/services/grails/plugin/jesque/JesqueService.groovy +++ b/grails-jesque/grails-app/services/grails/plugin/jesque/JesqueService.groovy @@ -18,7 +18,6 @@ import org.springframework.beans.factory.DisposableBean class JesqueService implements DisposableBean { static transactional = false - static scope = 'singleton' static final int DEFAULT_WORKER_POOL_SIZE = 3 diff --git a/grails-jesque/grails-app/services/grails/plugin/jesque/ScheduledJobDaoService.groovy b/grails-jesque/grails-app/services/grails/plugin/jesque/ScheduledJobDaoService.groovy index 67bf1f8..951687d 100644 --- a/grails-jesque/grails-app/services/grails/plugin/jesque/ScheduledJobDaoService.groovy +++ b/grails-jesque/grails-app/services/grails/plugin/jesque/ScheduledJobDaoService.groovy @@ -4,6 +4,8 @@ import redis.clients.jedis.Jedis class ScheduledJobDaoService { + static transactional = false + def redisService void save( ScheduledJob scheduledJob ) { diff --git a/grails-jesque/grails-app/services/grails/plugin/jesque/TriggerDaoService.groovy b/grails-jesque/grails-app/services/grails/plugin/jesque/TriggerDaoService.groovy index d5c210b..bd7dd01 100644 --- a/grails-jesque/grails-app/services/grails/plugin/jesque/TriggerDaoService.groovy +++ b/grails-jesque/grails-app/services/grails/plugin/jesque/TriggerDaoService.groovy @@ -4,6 +4,8 @@ import redis.clients.jedis.Jedis class TriggerDaoService { + static transactional = false + def redisService void save( Trigger trigger) {