java - Spring integration dsl: http outbound gateway -


faced spring integration java-dsl issue, i'm stuck. code have flow declaration:

    @bean     public integrationflow orchestrationflow() {         return integrationflows.from(                 jms.messagedrivenchanneladapter(queueconnectionfactory())                         .destination(bookingqueue())                         .outputchannel(bookingchannel()))                 .<string, bookingrequest>transform(s -> {                     ticket t = new gson().fromjson(s, ticket.class);                     return new bookingrequest()                             .setmovieid(t.getmovie().getid())                             .setrow(t.getseat().getrow())                             .setseat(t.getseat().getnumber())                             .setscreennumber(t.getscreennumber()                             );                 })                 // http part goes here                 .<bookingrequest, httpentity>transform(httpentity::new)                 .handle(                         http.outboundchanneladapter(bookingserverurl)                                 .httpmethod(httpmethod.post)                                 .extractpayload(true)                                 .expectedresponsetype(bookstatus.class)                 )                 // , here http part ends                 .handle(                         jms.outboundadapter(responsedestinationtemplate())                 )                 .get();     }

and ok until utilized http outbound channel adapter. need call simple restful interface , code above pretty well. but, following jms.outboundadapter(responsedestinationtemplate()) line leads nothing, no action performes after successfull http call.

if remove http flow part (surrounded comments) - works. implemented stuff, understood , saw beauty , simplicity of integration ...aand it. yet place got stuck in.

and here log after success rest call:

2016-02-08 21:01:22.155 debug 18209 --- [enercontainer-1] o.s.web.client.resttemplate              : post request "http://localhost:9052/api/book" resulted in 200 (ok) 2016-02-08 21:01:22.156 debug 18209 --- [enercontainer-1] o.s.web.client.resttemplate              : reading [class c.e.m.integration.domain.bookstatus] "application/json;charset=utf-8" using [org.springframework.http.converter.json.mappingjackson2httpmessageconverter@6b9469bd] 2016-02-08 21:01:22.168 debug 18209 --- [enercontainer-1] i.h.o.httprequestexecutingmessagehandler : handler 'org.springframework.integration.http.outbound.httprequestexecutingmessagehandler#0' produced no reply request message: genericmessage [payload=<bookingrequest(movieid=0, row=1, seat=1, screennumber=1),{}>, headers={jms_redelivered=false, jms_replyto=queue://statuschannel, jms_correlationid=5021291a-d4d5-47ca-b591-b6f311378688, correlationid=1d41f05a-3695-4adb-87b0-d75c17bbc3ad, id=a1fb2a2f-5d78-3183-d409-3f60aae74a20, priority=4, jms_timestamp=1454950877264, jms_messageid=id:ins-laptop-31198-1454948247657-1:9:1:1:1, timestamp=1454950877352}] 2016-02-08 21:01:22.168 debug 18209 --- [enercontainer-1] o.s.integration.channel.directchannel    : postsend (sent=true) on channel 'inboundflow.channel#2', message: genericmessage [payload=<bookingrequest(movieid=0, row=1, seat=1, screennumber=1),{}>, headers={jms_redelivered=false, jms_replyto=queue://statuschannel, jms_correlationid=5021291a-d4d5-47ca-b591-b6f311378688, correlationid=1d41f05a-3695-4adb-87b0-d75c17bbc3ad, id=a1fb2a2f-5d78-3183-d409-3f60aae74a20, priority=4, jms_timestamp=1454950877264, jms_messageid=id:ins-laptop-31198-1454948247657-1:9:1:1:1, timestamp=1454950877352}] 2016-02-08 21:01:22.168 debug 18209 --- [enercontainer-1] o.s.integration.channel.directchannel    : postsend (sent=true) on channel 'inboundflow.channel#1', message: genericmessage [payload=bookingrequest(movieid=0, row=1, seat=1, screennumber=1), headers={jms_redelivered=false, jms_replyto=queue://statuschannel, jms_correlationid=5021291a-d4d5-47ca-b591-b6f311378688, correlationid=1d41f05a-3695-4adb-87b0-d75c17bbc3ad, id=859af23d-214f-4400-e9cb-7d40308755cd, priority=4, jms_timestamp=1454950877264, jms_messageid=id:ins-laptop-31198-1454948247657-1:9:1:1:1, timestamp=1454950877350}] 2016-02-08 21:01:22.168 debug 18209 --- [enercontainer-1] o.s.integration.channel.directchannel    : postsend (sent=true) on channel 'inboundflow.channel#0', message: genericmessage [payload={"screennumber":1,"seat":{"row":1,"number":1},"movie":{"id":0,"name":"the matrix"}}, headers={jms_redelivered=false, jms_replyto=queue://statuschannel, jms_correlationid=5021291a-d4d5-47ca-b591-b6f311378688, correlationid=1d41f05a-3695-4adb-87b0-d75c17bbc3ad, id=636638ed-aec2-082e-6181-0484999fd807, priority=4, jms_timestamp=1454950877264, jms_messageid=id:ins-laptop-31198-1454948247657-1:9:1:1:1, timestamp=1454950877331}]

no errors, no warnings @ all.

spring integration provides 2 messagehandler types: one-way - handle message , stop. , 1 like: handle request message , produce reply output channel.

the first 1 called outboundchanneladapter , http case send post request , don't worry reply.

since message flow stopped on outboundchanneladapter no further action possible in integration chain. in case next jms.outboundadapter won't reached.

if expect reply rest service should use http.outboundgateway instead. , bookstatus sent jms you'd last .handle() in flow.


Comments

Post a Comment

Popular posts from this blog

java - pagination of xlsx file to XSSFworkbook using apache POI -

right in code, reading xlsx file, xssfworkbook, , writing database. but, when size of xlsx file increases, causes outofmemory error. can not increase server size, or divide xlsx file pieces. tried loading workbook using file (instead of inputstream), didn't either. i looking way read 10k rows @ time (instead of entire file @ once) , iteratively write workbook , database. is there way apache poi? poi contains called "eventmodel" designed purpose. it's mentioned in faq : the ss eventmodel package api reading excel files without loading whole spreadsheet memory. require more knowledge on part of user, reduces memory consumption more tenfold. based on awt event model in combination sax. if need read-only access, best way it. however, may want double check first if issue somewhere else. check out this item : i think poi using memory! can do? 1 comes quite lot, reason isn't might think. so, first thing check - what's source of prob...
Read more

Unlimited choices in BASH case statement -

consider simple bash snippet: case $option in 1) image=${options[0]%.tar} ;; 2) image=${options[1]%.tar} ;; 3) image=${options[2]%.tar} ;; 4) image=${options[3]%.tar} ;; *) echo "invalid option" exit 1 esac in real script numbers goes 30. makes pretty long. can somehow specify cases variable? something this: case $option in $i) image=${options[$(($i-1))]%.tar} any pointer appreciated. you can match against multiple patterns in single clause: case $option in 1|2|3: echo "$option one, 2 or three" ;; esac if still typing you, can use simple pattern matching: case $option in # following matches # - single-digit numbers 0-9 # - two-digit numbers starting either 1 or 2 # - number 30 [0-9]|[12][0-9]|30) image=${options[$(($option-1))]%.tar} ;; *) echo "invalid option" 1>&2 exit 1 esac
Read more

apache - How do I stop my index.php being run twice for every user -

we've got webapp initial html served using apache , php. i noticed index.php being run twice every request. seems caused / effected rewrite rules in our .htaccess - rewritecond %{http_host} ^(www\.|hotels\.)ourdomain\.com$ [nc,or] rewritecond %{server_name} ^(www\.|hotels\.)ourdomain\.com$ [nc] rewriterule (.*) http://ourdomain.com/$1 [r=301] rewriterule ^hotels/([^/]+)/?\??(.*)$ ?d=$1&$2 [qsa] the final rule moving parameter url path query string. i.e. http://ourdomain.com/hotels/vegas?someparam=1 becomes http://ourdomain.com?d=vegas&someparam=1 if go directly query string version index.php run once. if use url redirected, index.php run twice (i'm checking adding error_log('end of index.php') file). so example going http://ourdomain.com/hotels/paris hits file twice http://ourdomain.com?d=paris hits once. i've seen this question , had @ blog mentioned , , can't find empty string url's (i've tried using yslow process). ...
Read more