1+ import org.aopalliance.aop.Advice
12import org.codehaus.groovy.grails.commons.ServiceArtefactHandler
23import org.grails.rabbitmq.AutoQueueMessageListenerContainer
34import org.grails.rabbitmq.RabbitConfigurationHolder
@@ -7,27 +8,17 @@ import org.grails.rabbitmq.RabbitQueueBuilder
78import org.grails.rabbitmq.RabbitServiceConfigurer
89import org.springframework.amqp.core.Binding
910import org.springframework.amqp.core.Queue
11+ import org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptorFactoryBean
1012import org.springframework.amqp.rabbit.core.RabbitAdmin
1113import org.springframework.amqp.rabbit.core.RabbitTemplate
1214import org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
1315import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
14- import org.springframework.retry.backoff.FixedBackOffPolicy ;
15- // import org.springframework.retry.interceptor.StatefulRetryOperationsInterceptor;
16- import org.springframework.retry.policy.SimpleRetryPolicy ;
17- import org.springframework.retry.support.RetryTemplate ;
18- import static org.springframework.amqp.core.Binding.DestinationType.QUEUE
19- import org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptorFactoryBean
20- import org.aopalliance.aop.Advice
21- import java.io.ByteArrayOutputStream ;
2216import org.springframework.amqp.support.converter.SimpleMessageConverter
23- import java.io.PrintStream ;
17+ import org.springframework.retry.backoff.FixedBackOffPolicy
18+ import org.springframework.retry.policy.SimpleRetryPolicy
19+ import org.springframework.retry.support.RetryTemplate
20+ import static org.springframework.amqp.core.Binding.DestinationType.QUEUE
2421
25- import org.slf4j.Logger ;
26- import org.slf4j.LoggerFactory ;
27- import org.springframework.amqp.core.AmqpTemplate ;
28- import org.springframework.amqp.core.Message ;
29- import org.springframework.amqp.rabbit.retry.MessageRecoverer ;
30- import org.springframework.beans.factory.annotation.Autowired ;
3122
3223class RabbitmqGrailsPlugin {
3324 // the plugin version
0 commit comments