API 参考

消息队列配置

消息队列模块配置说明。

消息队列配置

配置前缀: nebula.messaging.rabbitmq

基础配置

nebula:
  messaging:
    rabbitmq:
      enabled: true
      host: localhost
      port: 5672
      username: guest
      password: guest
      virtual-host: /
      connection-timeout: 60000        # 连接超时(ms)
      heartbeat: 60                    # 心跳间隔(秒)
      automatic-recovery: true         # 自动恢复
      network-recovery-interval: 5000  # 网络恢复间隔(ms)

消费者配置

nebula:
  messaging:
    rabbitmq:
      consumer:
        prefetch-count: 1              # 预取数量
        auto-ack: false                # 自动确认
        retry-count: 3                 # 重试次数
        retry-interval: 1000           # 重试间隔(ms)

生产者配置

nebula:
  messaging:
    rabbitmq:
      producer:
        publisher-confirms: true       # 发送确认
        confirm-timeout: 5000          # 确认超时(ms)
        publisher-returns: true        # 发送回调

Exchange 配置

nebula:
  messaging:
    rabbitmq:
      exchange:
        default-type: topic            # 默认类型: direct, topic, fanout, headers
        durable: true                  # 持久化
        auto-delete: false             # 自动删除

延时消息配置

nebula:
  messaging:
    rabbitmq:
      delay-message:
        enabled: true
        default-max-retries: 3
        default-retry-interval: 1000
        max-delay-millis: 604800000    # 最大延时(7天)
        min-delay-millis: 1000         # 最小延时(1秒)
        auto-create-resources: true    # 自动创建资源
        enable-dead-letter-queue: true # 启用死信队列
        dead-letter-exchange: nebula.dlx.exchange
        dead-letter-queue: nebula.dlx.queue