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__");