Error handling with Http Outbound Gateway in Spring Integration


Error handling with Http Outbound Gateway in Spring Integration



I'm trying to understand how errors should be handled in Spring Integration. I found documentation about errorChannel, I tried to use it but the exception is not caught.


errorChannel



Here is my HTTP outbound gateway:


<int-http:outbound-gateway id="orderRequestHttpGateway"
request-channel="orders-channel"
url="${url}"
http-method="POST"
expected-response-type="java.lang.String"
reply-timeout='5000'
reply-channel='pushed-channel'
charset="UTF-8">
</int-http:outbound-gateway>



I don't understand where I should catch exceptions thrown by this component (like a 500 HTTP error)



The route is started by a poller. I tried adding an error-channelproperty:


poller


error-channel


<int:inbound-channel-adapter channel="orders-trigger-channel" expression="''">
<int:poller fixed-delay="${poller}" error-channel="errorChannel"/>
</int:inbound-channel-adapter>



I tried with a custom error channel. I also tried to override the existing errorChannel:


<int:channel id="errorChannel"/>
<int:outbound-channel-adapter id="errorChannelHandler"
ref="errorManager"
method="foo"
channel="errorChannel"/>



So far I keep getting MessageHandlingException and I can't catch them to deal with them properly.


MessageHandlingException




1 Answer
1



You catch exception only in the caller thread or in the place where you have a try...catch - there is nothing different in Spring Integration from pure Java: we catch exception whenever we have a try...catch.


try...catch


try...catch



According your description, the error-channel="errorChannel" on the <poller> is the way to go and if you don't have any other thread shifting downstream, such a MessageHandlingException is really thrown to the poller and wrapped into the ErrorMessage to be sent to that errorChannel configured.


error-channel="errorChannel"


<poller>


MessageHandlingException


ErrorMessage


errorChannel



It is a MessageHandlingException because we deal with the Messaging in Spring Integration and such an exception carries some context and important information about the flow and failed message. Your 500 HTTP error is just a cause in that message. So, when you catch and handle an ErrorMessage you should take a look into its stack trace for the information to parse.


MessageHandlingException


Messaging


500 HTTP error


cause


ErrorMessage



On the other hand you can narrow a scope for the error handling via ExpressionEvaluatingRequestHandlerAdvice or RequestHandlerRetryAdvice: https://docs.spring.io/spring-integration/docs/5.0.6.RELEASE/reference/html/messaging-endpoints-chapter.html#message-handler-advice-chain


ExpressionEvaluatingRequestHandlerAdvice


RequestHandlerRetryAdvice






By clicking "Post Your Answer", you acknowledge that you have read our updated terms of service, privacy policy and cookie policy, and that your continued use of the website is subject to these policies.

-

Popular posts from this blog

api-platform.com Unable to generate an IRI for the item of type

api-platform.com Unable to generate an IRI for the item of type I'm trying to setup my first api-platform instance and have run into some presumably noob questions around IDE. What i'm trying to do is setting up an register and reset entity in order to deal with registrations and password reminders from an app. And then have the entity's passed to a custom controller to do some checks, balances and mails afterwards (haven’t gotten around to that yet). But I keep running into this error when posting to my custom entities: { "@context": "/api/contexts/Error", "@type": "hydra:Error", "hydra:title": "An error occurred", "hydra:description": "Unable to generate an IRI for the item of type "AppXXXUserBundleEntityRegister"", "trace": [ { "namespace": "", "short_class": "", "c
Read more

How to set up datasource with Spring for HikariCP?

How to set up datasource with Spring for HikariCP? Hi I'm trying to use HikariCP with Spring for connection pool. I'm using jdbcTempLate and JdbcdaoSupport. This is my spring configuration file for datasource: <bean id="dataSource" class="com.zaxxer.hikari.HikariDataSource"> <property name="dataSourceClassName" value="oracle.jdbc.driver.OracleDriver"/> <property name="dataSource.url" value="jdbc:oracle:thin:@localhost:1521:XE"/> <property name="dataSource.user" value="username"/> <property name="dataSource.password" value="password"/> </bean> But unfortunately the following error message is generating: Cannot resolve reference to bean 'dataSource' while setting bean property 'dataSource'; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'dataSource'
Read more

Display dokan vendor name on Woocommerce single product pages

Display dokan vendor name on Woocommerce single product pages With woocommerce I am using Dokan plugin and I am trying to display the vendor name, rating and vendor location on single product pages. I tried this code to display vendor name but no luck: //show store name add_action( 'woocommerce_single_product_summary', 'show_store_name', 20 ); function show_store_name() { printf( '<b>Seller Name:</b> <a href="%s">%s</a>', dokan_get_store_url( $author->ID ), $store_info['store_name'] ); } Any help is appreciated. 1 Answer 1 I don't use dokan plugin. Here is the way to get the (post) author ID and to make your code work: add_action( 'woocommerce_single_product_summary', 'display_author_name', 20 ); function display_author_name() { // Get the author ID (the vendor ID) $vendor_id = get_post_field( &#
Read more