KH/kh-device-admin
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/fix-bug-202303' into fix-bug-202303

Browse Source
This commit is contained in:
梁琦涛
2023-03-09 17:47:15 +08:00
parent e56df48598 522cb7fd61
commit 81f0708ade
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
jero-boot/jero-boot-starter/jero-boot-starter-rabbitmq/src/main/java/com/jero/boot/starter/rabbitmq/exchange/DelayExchangeBuilder.java
+6 -3
View File
@@ -15,18 +15,21 @@ public class DelayExchangeBuilder {
/** /**
* 默认延迟消息交换器 * 默认延迟消息交换器
*/ */
public final static String DEFAULT_DELAY_EXCHANGE = "jero.delayed.exchange"; public static final String DEFAULT_DELAY_EXCHANGE = "jero.delayed.exchange";
/** /**
* 普通交换器 * 普通交换器
*/ */
public final static String DELAY_EXCHANGE = "jero.direct.exchange"; public static final String DELAY_EXCHANGE = "jero.direct.exchange";
private DelayExchangeBuilder() {
}
/** /**
* 构建延迟消息交换器 * 构建延迟消息交换器
* @return * @return
*/ */
public static CustomExchange buildExchange() { public static CustomExchange buildExchange() {
Map<String, Object> args = new HashMap<String, Object>(); Map<String, Object> args = new HashMap<>();
args.put("x-delayed-type", "direct"); args.put("x-delayed-type", "direct");
return new CustomExchange(DEFAULT_DELAY_EXCHANGE, "x-delayed-message", true, false, args); return new CustomExchange(DEFAULT_DELAY_EXCHANGE, "x-delayed-message", true, false, args);
} }