java - JMS Message Selector doesn't work in Multi-Server Environment -


i've implemented spring jms hornetq. works if 1 app-server hornetq. if 2 app servers accessing hornetq. doesn't work. inorder identify different server i've introduced clientid, still doesn't work. here flow.

  1. prepare message send clientid(unique serverid sending message) correlation id , send horentq quename 'q1' producercallback , wait response.

    request.setstringproperty("clientid", clientid); request.setjmscorrelationid(correlationid);

  2. in consumder side i've defaultmessagelistenercontainer listening queue q1. once message received process , set correlaionid , clientid in response object , send q 'q2'

    final string clientid = request.getstringproperty("clientid"); final string correlationid = request.getjmscorrelationid();   response.setjmscorrelationid(correlationid); response.setstringproperty("clientid", clientid);

  3. in sender side i've defaultmessagelistenercontainer listening q2. message selector select message based on clientid.

    <bean id="jmscontatiner"     class="org.springframework.jms.listener.defaultmessagelistenercontainer">     <property name="messageselector" value="clientid='server1'" />     <property name="concurrency" value="1" />     <property name="messagelistener" ref="responselistener" />     <property name="destinationname" value="q2" />     <property name="connectionfactory" ref="connectionfactory" /> </bean>

the code works fine when 1 server envolved. second server's message never recieved listener in server, listens q2(as see in jconsole of hornetq). here happens.
server1 sends message q1 , consumer receives message processes , puts on q2 , server1 receives message q1 selecting message on clientid server1. when server2 sends message q1 , consumer receives message processes , puts on q2. server2 listener not able select message based on clientid server2. when restart server , start of test server2, notw server2 works server1 doesn't pick message.

any appreciated.

fixed issue added cache level cache_connection , client id. started working perfectly.

<bean id="jmscontatiner"     class="org.springframework.jms.listener.defaultmessagelistenercontainer">     <property name="messageselector" value="clientid='server1'" />     <property name="concurrency" value="1" />     <property name="clientid" value="server1" />     <property name="cachelevel" value="1" />     <property name="messagelistener" ref="responselistener" />     <property name="destinationname" value="q2" />     <property name="connectionfactory" ref="connectionfactory" /> </bean>

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