From fa839d5d869a2fa68872bf85282516a8c450ef05 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=BA=A6=E7=9B=8F?= Date: Fri, 11 Mar 2022 17:14:04 +0800 Subject: [PATCH] to #77,support throw mock exception --- .../main/java/com/alibabacloud/mse/demo/CApplication.java | 7 +++++++ .../alibabacloud/mse/demo/service/HelloServiceCImpl.java | 8 ++++++++ 2 files changed, 15 insertions(+) diff --git a/mse-simple-demo/C/src/main/java/com/alibabacloud/mse/demo/CApplication.java b/mse-simple-demo/C/src/main/java/com/alibabacloud/mse/demo/CApplication.java index 4100dac9..da471938 100644 --- a/mse-simple-demo/C/src/main/java/com/alibabacloud/mse/demo/CApplication.java +++ b/mse-simple-demo/C/src/main/java/com/alibabacloud/mse/demo/CApplication.java @@ -19,6 +19,7 @@ import javax.servlet.http.HttpServletRequest; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.loadbalancer.LoadBalanced; @@ -55,8 +56,14 @@ class AController { @Autowired InetUtils inetUtils; + @Value("${throwException:false}") + boolean throwException; + @GetMapping("/c") public String c(HttpServletRequest request) { + if (throwException) { + throw new RuntimeException(); + } return "C" + SERVICE_TAG + "[" + inetUtils.findFirstNonLoopbackAddress().getHostAddress() + "]"; } } diff --git a/mse-simple-demo/C/src/main/java/com/alibabacloud/mse/demo/service/HelloServiceCImpl.java b/mse-simple-demo/C/src/main/java/com/alibabacloud/mse/demo/service/HelloServiceCImpl.java index 0271129a..425c12dc 100644 --- a/mse-simple-demo/C/src/main/java/com/alibabacloud/mse/demo/service/HelloServiceCImpl.java +++ b/mse-simple-demo/C/src/main/java/com/alibabacloud/mse/demo/service/HelloServiceCImpl.java @@ -28,9 +28,17 @@ public class HelloServiceCImpl implements HelloServiceC { @Value("${rocketmq.consumer.topic}") private String topic; + + @Value("${throwException:false}") + boolean throwException; + @Override public String hello(String name) { + if (throwException) { + throw new RuntimeException(); + } + String value = "C" + SERVICE_TAG + "[" + inetUtils.findFirstNonLoopbackAddress().getHostAddress() + "]"; String invokerTag=""; String userData = RpcContext.getContext().getAttachment("__microservice_tag__");