소스 검색

消息队列配置优化

macro 3 년 전
부모
커밋
2bc0bea2ea
1개의 변경된 파일2개의 추가작업 그리고 2개의 파일을 삭제
  1. 2 2
      mall-portal/src/main/java/com/macro/mall/portal/config/RabbitMqConfig.java

+ 2 - 2
mall-portal/src/main/java/com/macro/mall/portal/config/RabbitMqConfig.java

@@ -17,7 +17,7 @@ public class RabbitMqConfig {
      */
     @Bean
     DirectExchange orderDirect() {
-        return (DirectExchange) ExchangeBuilder
+        return ExchangeBuilder
                 .directExchange(QueueEnum.QUEUE_ORDER_CANCEL.getExchange())
                 .durable(true)
                 .build();
@@ -28,7 +28,7 @@ public class RabbitMqConfig {
      */
     @Bean
     DirectExchange orderTtlDirect() {
-        return (DirectExchange) ExchangeBuilder
+        return ExchangeBuilder
                 .directExchange(QueueEnum.QUEUE_TTL_ORDER_CANCEL.getExchange())
                 .durable(true)
                 .build();