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