Обработка исключений и прерывание потока в Mule 3.9 - PullRequest
Новая
       71

Обработка исключений и прерывание потока в Mule 3.9

0 голосов
/ 23 марта 2020


У меня проблема с одним случаем в Mule 3.9. У меня есть мой API, созданный с помощью этого файла .raml. Одной из конечных точек является просто GET с маршрутом "/" (для целей тестирования). В этом потоке (управление GET /) я хотел бы вызвать другой поток для проверки sth (в моем случае проверка JWT). Когда действует, я хотел бы передать и вернуть исходную полезную нагрузку. Когда это недопустимо, я вызываю исключение в Groovy, которое действительно происходит, но, в конце концов, оно имеет ту же исходную полезную нагрузку, которая не должна быть видимой.

Давайте создадим некоторый код:

исходный поток: 

        <flow-ref name="validate_jwt_token" doc:name="Validate JWT"/>

        <set-payload value=" { &quot;message&quot; : &quot;API is working!&quot;}" doc:name="Set Payload" mimeType="application/json" />
    </flow>

и ссылка ref: 

<flow name="validate_jwt_token">
        <logger message="Request found with Authorization: #[message.inboundProperties['authorization']]" level="INFO" doc:name="Loger Authorization"/>
        <component doc:name="Validate JWT Token">
            <spring-object bean="ValidateJWTEvent"/>
        </component>
        <choice doc:name="Choice">
             <when expression="(payload == true)">
                <logger message="JWT valid. Access granted." level="INFO" doc:name="Logger"/>
            </when>
             <otherwise>

                <scripting:component doc:name="Throw Exception">
                    <scripting:script engine="Groovy"><![CDATA[throw new Exception('Invalid JWT Token.')]]></scripting:script>
                </scripting:component>
            </otherwise>
        </choice>
          <catch-exception-strategy doc:name="Catch Exception Strategy">
            <set-property propertyName="http.status" value="401" doc:name="Set 401 status"/>
            <flow-ref name="commons.exceptionStrategy.logError" doc:name="Log errors"/>
        </catch-exception-strategy>


    </flow>

И даже если этот токен фактически недействителен, я получаю ту же полезную нагрузку с текстом «API IS ЗА РАБОТОЙ". Я хочу перехватить исключение и вернуть HTTP ERROR. Ничего больше.

Я также прилагаю свою стратегию исключения. Пожалуйста, имейте в виду, что он основан на APIKIT, сгенерированном файле Mule itselft .raml. 

 <sub-flow name="commons.exceptionStrategy.logError">
        <logger message="Error: #[exception.?cause.message or exception]" level="ERROR" doc:name="Logger" />

        <set-property propertyName="Content-Type" value="application/json" doc:name="Set Content Type"/>
        <flow-ref name="log_params" doc:name="log_params"/>
        <logger message="#[org.apache.commons.lang3.StringEscapeUtils.escapeJson(exception.?getCauseException().?getMessage())]" level="ERROR" doc:name="Display error"/>
        <set-payload value="{ &quot;responseHeader&quot;: { &quot;requestId&quot;: &quot;#[flowVars.storedRequestId]&quot;, &quot;sendDate&quot;: &quot;#[function:now]&quot;}, &quot;code&quot;: &quot;#[flowVars.'statusCode']&quot;, &quot;message&quot;: &quot;#[flowVars.errorMessage or org.apache.commons.lang3.StringEscapeUtils.escapeJson(exception.?getCauseException().?getMessage())]&quot; }" doc:name="Set Error Message"/>
     </sub-flow>

 <sub-flow name="log_params">

<logger message="API| endpoint executed with payload: #[message.payload]" level="INFO" doc:name="log payload"/>
        <logger message="API| endpoint executed with flowVars: #[flowVars]" level="INFO" doc:name="log params"/>

        </sub-flow>

Весь API используется APIKIT my Mule со стратегией исключения глобальных уловов.

Пожалуйста помогите мне, ребята.

1 Ответ

0 голосов
/ 04 апреля 2020

Похоже, что вы перехватываете исключение в том же потоке, что и его. Следовательно, он не распространяется, и поток не прерывается, поскольку обработано исключение. Попробуйте вместо этого использовать стратегию отката-исключения, которая изменит полезную нагрузку, но распространит исключение на ссылку потока вызывающей стороны и прервет этот поток. НТН

...