paulwong

          EVEN DRIVEN - SPRING CLOUD STREAM - Error Handling

          如果Function中拋出異常,系統沒有配置捕獲異常,則異常消息會被丟棄。通常會進行配置。

          @ServiceActivator(inputChannel = "my-destination.my-group.errors")
              public void handleError(ErrorMessage message) {
                  Throwable throwable = message.getPayload();
                  log.error("截獲異常", throwable);

                  Message<?> originalMessage = message.getOriginalMessage();
                  assert originalMessage != null;

                  log.info("原始消息體 = {}", new String((byte[]) originalMessage.getPayload()));
              }

          詳情參考:
          https://www.itmuch.com/spring-cloud/spring-cloud-stream-error-handling/

          posted on 2021-11-17 10:50 paulwong 閱讀(243) 評論(0)  編輯  收藏 所屬分類: SPRING CLOUDEVEN DRIVEN ARCHITECT

          主站蜘蛛池模板: 克拉玛依市| 长白| 高淳县| 满城县| 鄂托克前旗| 卓尼县| 双桥区| 文安县| 东光县| 桂平市| 囊谦县| 上林县| 叙永县| 梁平县| 邓州市| 沂源县| 台前县| 寻乌县| 高碑店市| 阿尔山市| 中西区| 马关县| 廉江市| 定远县| 杂多县| 周口市| 阿拉尔市| 元朗区| 望江县| 宁晋县| 夏津县| 高碑店市| 民乐县| 万全县| 庐江县| 清镇市| 饶阳县| 鄂尔多斯市| 田东县| 射洪县| 岑溪市|