spring integration - Intermittent BridgeHandler & PublishSubscribeChannel call when gateways' reply channel is pub/sub -


i'm seeing weird behaviour when sending data through channels. i'm using si gateway when sending message processed. gateway setup below

<integration:gateway id="rptpubgateway"     default-request-channel="rptpubinchannel"     default-reply-channel="rptoutputavailablechannel"     default-reply-timeout="60000"     service-interface="xxxx.rptpubgateway" />

the reply channel being set publish/subscribe channel

<integration:publish-subscribe-channel id="rptoutputavailablechannel" />

the last service processes message being declared below

<integration:service-activator input-channel="rptoutputavailablechannel" ref="requestmessagehandler" method="rptisdone" output-channel="nullchannel"/>

now, issue have while code works fine of time, fails sometimes. when works fine last component processing message publishsubschannel

 publishsubscribechannel - presend on channel 'rptoutputavailablechannel'

but when fails last component becomes bridgerhandler

bridgehandler@e851a798' sending reply message:

i should mention there no exceptions being thrown while processing message. (after failure can resend same message , work ok)

i'm not sure how bridgerhandler gets created. know bridge gets created pub/subs channels why don't see in log when works fine ?

i'd appreciate help

when "fails" mean?

what other consumers on rptoutputavailablechannel?

the bridgehandler see internal bridge message's replychannel header, reply must go. when explicitly sending rptoutputavailablechannel, bridge handler always invoked reply message's temporary reply channel.


Comments

Post a Comment

Popular posts from this blog

javascript - RequestAnimationFrame not working when exiting fullscreen switching space on Safari -

request animation frame stops working when exiting fullscreen clicking on original space's safari window. fine if fullscreen mode canceled escape key or calling cancelfullscreen(). steps reproduce: open https://dl.dropboxusercontent.com/u/769042/prezi/safari-fullscreen.html click "draw raf", kittie appears click "fullscreen", go fullscreen click "draw raf", kittie appears go space original safari was, showing "click exit fullscreen mode", click anywhere, out fullscreen click "draw raf", nothing happens what handling click calling: window.requestanimationframe(draw); which draws on canvas context: function draw() { ctx.drawimage(img, math.random()*500|0, math.random()*400|0, 100, 100); } i checked .hidden , .visibilitystate, updated correctly. tested on osx 10.9.3, safari 7.0.4 (9537.76.4). has workaround/solution other switching old settimeout? this sounds webkit bug 88940 : using reque
Read more

Python ctypes access violation with const pointer arguments -

i have api i'm trying wrap in python (2.7.6 on win7) code using ctypes. here's api: client_dllfunc bool clientapi search_exporttoclipcopy(clienthsearch handle, int channel, lpctstr filename, const time_t& from, const time_t& to, const bool* cameras, int length, bool usepassword, lpctstr password, bool includetextin = false, bool excludeplayer = false); the issue i'm having cameras argument; , i've had issue other const pointer arguments well. here's how i'm wrapping api: def search_exporttoclipcopy(self, hsearch, csearch, filename, tfrom, tto, cameras, length, usepassword, password, includetextin=true, excludeplayer=false): exporttoclipcopy = self.sdkdll.search_exporttoclipcopy exporttoclipcopy.argtypes = [c_int, c_int, c_wchar_p, c_long, c_long, pointer(c_bool), c_int, c_bool, c_wchar_p, c_bool, c_bool] exporttoclipcopy.restype = c_bool exporttoclipcopy(hsearch, csearch, filename, tfrom, tto, cameras, length, usepassword, pass
Read more