Http Inbound Gateway Problem

Guys,

I think that it could be related to threading and http.... maybe I'm wrong but let me explain:

Subscriber is using a couple of threads to call to the both services. Probably is reusing a existing one thread to call to service1 and creating a new one to call to service2 (no idea, just a guess). What about if http is expecting the response in the thread1 but the response is arriving in the thread2???? when response arrives in thread 1, works! when response arrives in thread 2.... fails!

just an Idea...

Quote:

---

it could be related to threading and http

---

So, let's increase log level to DEBUG for org.springframework.integration category with Thread-Id indicator <%t>:!
And also add this config:

HTML Code:

---

<si:message-history/>
<si:wire-tap channel="logger"/>
<si:logging-channel-adapter id="logger" level="WARN"/>

---

to see how Messages are traveling.

By the way don't your transformers return entire Message?..

Well, the reply would go to the replyChannel defined in the Message headers so since you have aggregator downstream the reply won't be received until you get the aggregated response. In other words the HTTP thread that sent a Message is going to be executing a receive call (blocking call) on the reply channel, so it doesn't matter how many threads are in action downstream.

BTW you can also remove this chain:

Code:

---

<int:chain input-channel="requestChannel" output-channel="messageSubscriber">
        <int:transformer ref="requestTransformer" />
</int:chain>

---

in favor of

Code:

---

<int:transformer input-channel="requestChannel" output-channel="messageSubscriber" ref="requestTransformer"/>

---

Anyway, definitely follow Artem's suggestion and let us know.

Hi again guys,

Finally I've fixed the problem, it was related with timeout, let me explain it.

I didn't set the reply-time-out property in my http-inbound-gateway:

Code:

---

<int-http:inbound-gateway
        request-channel="requestChannel"
        name="/req"
        supported-methods="GET"
        mapped-request-headers="*"/>

---

Seems that the default timeout is 1 second, so when my services spend more than 1 second, the gateway returns an empty payload and a httpStatus 200 due to timeout "error".

This's weird, because I would expect some kind of error (500) in case of timeout, but not a 200-OK. Is this ok?

The fix has been easy, just set the reply-timeout property with the proper amount of seconds:

Code:

---

<int-http:inbound-gateway
        request-channel="requestChannel"
        name="/req"
        supported-methods="GET"
        mapped-request-headers="*"
        reply-timeout="30000"/>

---

Thanks!