Browse Source

7.31 查看并处理边民退单、退款请求(确认退款)

Mechrevo 1 year ago
parent
commit
bad48857b7
1 changed files with 15 additions and 1 deletions
  1. 15 1
      sp-service/level-one-server/src/main/java/com/pj/LevelOneServer.java

+ 15 - 1
sp-service/level-one-server/src/main/java/com/pj/LevelOneServer.java

@@ -1,10 +1,14 @@
 package com.pj;
 
+import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
+import org.springframework.amqp.support.converter.MessageConverter;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.context.ApplicationPidFileWriter;
 import org.springframework.cache.annotation.EnableCaching;
 import org.springframework.cloud.openfeign.EnableFeignClients;
+import org.springframework.context.annotation.Bean;
+import org.springframework.retry.annotation.EnableRetry;
 import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.transaction.annotation.EnableTransactionManagement;
 
@@ -21,7 +25,8 @@ import java.util.Properties;
 @EnableScheduling // 启动定时任务
 @SpringBootApplication // springboot本尊
 @EnableTransactionManagement // 启动注解事务管理
-@EnableFeignClients		// 启用Feign实现RPC调用  
+@EnableFeignClients		// 启用Feign实现RPC调用
+@EnableRetry   // 开启失败重试机制
 public class LevelOneServer {
 	
 	public static void main(String[] args) {
@@ -33,4 +38,13 @@ public class LevelOneServer {
 		SpCloudUtil.printCurrentServiceInfo();
 	}
 
+	/**
+	 * 消息转换器
+	 * @return
+	 */
+	@Bean
+	public MessageConverter messageConverter(){
+		return new Jackson2JsonMessageConverter();
+	}
+
 }