java.lang.Object
io.github.mangocrisp.spring.taybct.common.message.cheduledlog.ScheduledLogMQConfig

@AutoConfiguration @ConditionalOnClass(org.springframework.amqp.rabbit.core.RabbitTemplate.class) public class ScheduledLogMQConfig extends Object
rabbit mq 自动创建队列配置
从以下版本开始:
1.0.0
  • 嵌套类概要

    嵌套类
    修饰符和类型
    说明
    static interface 
    exchange 和 queue 的 key
  • 构造器概要

    构造器
    构造器
    说明
     
  • 方法概要

    修饰符和类型
    方法
    说明
    org.springframework.amqp.core.Binding
    scheduledLogBinding(org.springframework.amqp.core.CustomExchange scheduledLogCustomExchange, org.springframework.amqp.core.Queue scheduledLogQueue)
    队列绑定交换机
    org.springframework.amqp.core.CustomExchange
    配置队列交换机
    org.springframework.amqp.core.Queue
    配置队列
    scheduledLogSendMQHandler(io.github.mangocrisp.spring.taybct.tool.core.message.MessageProperties messageProperties, org.springframework.amqp.rabbit.core.RabbitTemplate rabbitTemplate, org.springframework.amqp.core.CustomExchange scheduledLogCustomExchange, org.springframework.amqp.core.Queue scheduledLogQueue, org.springframework.amqp.core.Binding scheduledLogBinding, io.github.mangocrisp.spring.taybct.tool.core.message.IMessageSendService messageSendService, org.springframework.amqp.core.AmqpAdmin amqpAdmin)
    配置消息发送处理器

    从类继承的方法 java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • 构造器详细资料

    • ScheduledLogMQConfig

      public ScheduledLogMQConfig()
  • 方法详细资料

    • scheduledLogQueue

      @Bean("scheduledLogQueue") public org.springframework.amqp.core.Queue scheduledLogQueue()
       配置队列
       
      返回:
      Queue
      从以下版本开始:
      2024/9/1 23:46
    • scheduledLogCustomExchange

      @Bean("scheduledLogCustomExchange") public org.springframework.amqp.core.CustomExchange scheduledLogCustomExchange()
       配置队列交换机
       
      返回:
      CustomExchange
      从以下版本开始:
      2024/9/1 23:47
    • scheduledLogBinding

      @Bean("scheduledLogBinding") public org.springframework.amqp.core.Binding scheduledLogBinding(@Qualifier("scheduledLogCustomExchange") org.springframework.amqp.core.CustomExchange scheduledLogCustomExchange, @Qualifier("scheduledLogQueue") org.springframework.amqp.core.Queue scheduledLogQueue)
       队列绑定交换机
       
      参数:
      scheduledLogCustomExchange - 交换机
      scheduledLogQueue - 队列
      返回:
      Binding
      从以下版本开始:
      2024/9/1 23:47
    • scheduledLogSendMQHandler

      @Bean("scheduledLogSendMQHandler") @ConditionalOnMissingBean(ScheduledLogSendMQHandler.class) public ScheduledLogSendMQHandler scheduledLogSendMQHandler(io.github.mangocrisp.spring.taybct.tool.core.message.MessageProperties messageProperties, org.springframework.amqp.rabbit.core.RabbitTemplate rabbitTemplate, @Qualifier("scheduledLogCustomExchange") org.springframework.amqp.core.CustomExchange scheduledLogCustomExchange, @Qualifier("scheduledLogQueue") org.springframework.amqp.core.Queue scheduledLogQueue, @Qualifier("scheduledLogBinding") org.springframework.amqp.core.Binding scheduledLogBinding, @Nullable io.github.mangocrisp.spring.taybct.tool.core.message.IMessageSendService messageSendService, @Nullable org.springframework.amqp.core.AmqpAdmin amqpAdmin)
       配置消息发送处理器
       
      参数:
      messageProperties - 配置
      rabbitTemplate - rabbit mq
      返回:
      ScheduledLogSendMQHandler
      从以下版本开始:
      2024/9/1 23:57