Package com.github.sonus21.rqueue.spring.boot

Class RqueueListenerAutoConfig

java.lang.Object
com.github.sonus21.rqueue.config.RqueueListenerBaseConfig
com.github.sonus21.rqueue.spring.boot.RqueueListenerAutoConfig
@Configuration @AutoConfigureAfter(org.springframework.boot.autoconfigure.data.redis.RedisAutoConfiguration.class) @ComponentScan({"com.github.sonus21.rqueue.web","com.github.sonus21.rqueue.dao"}) @Conditional(com.github.sonus21.rqueue.utils.condition.RqueueEnabled.class) public class RqueueListenerAutoConfig extends com.github.sonus21.rqueue.config.RqueueListenerBaseConfig

  • Field Summary

    Fields inherited from class com.github.sonus21.rqueue.config.RqueueListenerBaseConfig

    MAX_DB_VERSION, reactiveEnabled, simpleRqueueListenerContainerFactory

  • Constructor Summary

    Constructors
    Constructor
    Description
    RqueueListenerAutoConfig()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    com.github.sonus21.rqueue.core.ReactiveRqueueMessageEnqueuer
    reactiveRqueueMessageEnqueuer(com.github.sonus21.rqueue.listener.RqueueMessageHandler rqueueMessageHandler, com.github.sonus21.rqueue.core.RqueueMessageTemplate rqueueMessageTemplate)
     
    com.github.sonus21.rqueue.core.RqueueEndpointManager
    rqueueEndpointManager(com.github.sonus21.rqueue.listener.RqueueMessageHandler rqueueMessageHandler, com.github.sonus21.rqueue.core.RqueueMessageTemplate rqueueMessageTemplate)
     
    com.github.sonus21.rqueue.core.RqueueMessageEnqueuer
    rqueueMessageEnqueuer(com.github.sonus21.rqueue.listener.RqueueMessageHandler rqueueMessageHandler, com.github.sonus21.rqueue.core.RqueueMessageTemplate rqueueMessageTemplate)
     
    com.github.sonus21.rqueue.listener.RqueueMessageHandler
    rqueueMessageHandler()
     
    com.github.sonus21.rqueue.listener.RqueueMessageListenerContainer
    rqueueMessageListenerContainer(com.github.sonus21.rqueue.listener.RqueueMessageHandler rqueueMessageHandler)
     
    com.github.sonus21.rqueue.core.RqueueMessageManager
    rqueueMessageManager(com.github.sonus21.rqueue.listener.RqueueMessageHandler rqueueMessageHandler, com.github.sonus21.rqueue.core.RqueueMessageTemplate rqueueMessageTemplate)
     
    com.github.sonus21.rqueue.core.RqueueMessageTemplate
    rqueueMessageTemplate(com.github.sonus21.rqueue.config.RqueueConfig rqueueConfig, com.github.sonus21.rqueue.listener.RqueueMessageHandler rqueueMessageHandler)
     

    Methods inherited from class com.github.sonus21.rqueue.config.RqueueListenerBaseConfig

    getMessageConverterProvider, getMessageTemplate, processingMessageScheduler, reactiveRqueueViewResolver, rqueueBeanProvider, rqueueConfig, rqueueInternalPubSubChannel, rqueueLockManager, rqueueQueueMetrics, rqueueRedisListenerContainerFactory, rqueueRedisLongTemplate, rqueueSchedulerConfig, rqueueStringDao, rqueueViewResolver, rqueueWebConfig, scheduledMessageScheduler, stringRqueueRedisTemplate

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • RqueueListenerAutoConfig

      public RqueueListenerAutoConfig()

  • Method Details

    • rqueueMessageHandler

      @Bean @ConditionalOnMissingBean public com.github.sonus21.rqueue.listener.RqueueMessageHandler rqueueMessageHandler()

    • rqueueMessageListenerContainer

      @Bean @DependsOn("rqueueConfig") @ConditionalOnMissingBean public com.github.sonus21.rqueue.listener.RqueueMessageListenerContainer rqueueMessageListenerContainer(com.github.sonus21.rqueue.listener.RqueueMessageHandler rqueueMessageHandler)

    • rqueueMessageTemplate

      @Bean @ConditionalOnMissingBean public com.github.sonus21.rqueue.core.RqueueMessageTemplate rqueueMessageTemplate(com.github.sonus21.rqueue.config.RqueueConfig rqueueConfig, com.github.sonus21.rqueue.listener.RqueueMessageHandler rqueueMessageHandler)

    • rqueueMessageManager

      @Bean @ConditionalOnMissingBean public com.github.sonus21.rqueue.core.RqueueMessageManager rqueueMessageManager(com.github.sonus21.rqueue.listener.RqueueMessageHandler rqueueMessageHandler, com.github.sonus21.rqueue.core.RqueueMessageTemplate rqueueMessageTemplate)

    • rqueueEndpointManager

      @Bean @ConditionalOnMissingBean public com.github.sonus21.rqueue.core.RqueueEndpointManager rqueueEndpointManager(com.github.sonus21.rqueue.listener.RqueueMessageHandler rqueueMessageHandler, com.github.sonus21.rqueue.core.RqueueMessageTemplate rqueueMessageTemplate)

    • rqueueMessageEnqueuer

      @Bean @ConditionalOnMissingBean public com.github.sonus21.rqueue.core.RqueueMessageEnqueuer rqueueMessageEnqueuer(com.github.sonus21.rqueue.listener.RqueueMessageHandler rqueueMessageHandler, com.github.sonus21.rqueue.core.RqueueMessageTemplate rqueueMessageTemplate)

    • reactiveRqueueMessageEnqueuer

      @Bean @ConditionalOnMissingBean @Conditional(com.github.sonus21.rqueue.utils.condition.ReactiveEnabled.class) public com.github.sonus21.rqueue.core.ReactiveRqueueMessageEnqueuer reactiveRqueueMessageEnqueuer(com.github.sonus21.rqueue.listener.RqueueMessageHandler rqueueMessageHandler, com.github.sonus21.rqueue.core.RqueueMessageTemplate rqueueMessageTemplate)