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 閱讀(241) 評論(0)  編輯  收藏 所屬分類: SPRING CLOUDEVEN DRIVEN ARCHITECT

          主站蜘蛛池模板: 广汉市| 伊通| 新丰县| 杭锦旗| 翁牛特旗| 句容市| 上高县| 长兴县| 长沙市| 古交市| 德惠市| 上栗县| 上饶市| 郁南县| 三门峡市| 赞皇县| 时尚| 梨树县| 安塞县| 华宁县| 犍为县| 抚顺市| 石柱| 江津市| 富锦市| 宁城县| 大足县| 手游| 文昌市| 乌兰浩特市| 隆化县| 攀枝花市| 鄂托克旗| 定边县| 巴林右旗| 尚志市| 电白县| 宝兴县| 梁平县| 新丰县| 临朐县|