java - Spring JMS listener receives empty messages causing CPU consumption -

-

i'm working on application uses couple of jms queues send/receive updates to/from external system. in order test application i'm using mockrunner , jms module. i'm facing strange behavior: when start application can see cpu skyrocketing @ 100% and, analyzing thread dumps, can see main reason related jms listeners have looks receiving empty messages causing messages like:

consumer ... did not receive message

now i'm trying understand if issue related bad interaction of app , mockrunner or configuration error.

the relevant parts of configuration are:

<bean id="destinationmanager" factory-bean="mockrunnerjmsobjectfactory" factory-method="getdestinationmanager" />  <bean id="mockjmsconnectionfactory" factory-bean="mockrunnerjmsobjectfactory" factory-method="createmockconnectionfactory" lazy-init="true"/>

and listener cause cpu spin indefinitely are:

<jms:listener-container concurrency="5" connection-factory="mockjmsconnectionfactory" destination-type="queue" message-converter="mymessageconverter" acknowledge="transacted" >     <jms:listener          id="mylistener"          destination="myqueue"          ref="myconsumer"          method="consume"     /> </jms:listener-container>  <bean id="myconsumer"... />

update opened issue on mockrunner project, can see here.

after investigation found out problem lies in bad interaction spring defaultmessagelistenercontainer. listener has polling-based implementation and, given mocked infrastructure fast when answering requests, cause cpu overload. patched mock runner adding ugly thread sleep in response method, maybe going fixed sooner or later.


Comments

Post a Comment

Popular posts from this blog

node.js - Mongoose: Cast to ObjectId failed for value on newly created object after setting the value -

-
this question has answer here: what's mongoose error cast objectid failed value xxx @ path “_id”? 7 answers even though has been asked many times because entity has no valid objectid field. i came across situation objectid set value can casted objectid still error. the schema: var serviceschema = parammongoose.schema({ servicename:{ type: parammongoose.schema.types.objectid , ref: 'servicenames',required:true } }); pseudo code: servicefromdb=new service({servicename:'some name'}); servicefromdb.servicename='000000000000000000000001'; servicefromdb.save(function(paramerror,paramdata){ if(paramerror){ console.log('but but...',servicefromdb,paramerror) } }); the output of code is: but but... { servicename: 000000000000000000000001, _id: 55079a90286f49280364f78b } { [casterror: cast objectid faile...
Read more

gradle error "Cannot convert the provided notation to a File or URI" -

-
i have defined 2 system properties in gradle.properties: systemprop.builddir=build systemprop.cfgdir=build\\cfg and have following task defined in build.gradle: task clean(group:'clean',description:'clean project') << { ant.sequential { delete(dir: system.properties.builddir) mkdir(dir: system.properties.builddir) delete(dir: system.properties.cfgdir) mkdir(dir: system.properties.cfgdir) } } this generates following error: execution failed task ':clean'. > cannot convert provided notation file or uri: {dir=build}. following types/formats supported: - string or charsequence path, e.g 'src/main/java' or '/usr/include' - string or charsequence uri, e.g 'file:/usr/include' - file instance. - uri or url instance. but equivalent block of code not generate error , works expected: task clean(group:'clean',description:'clean project') << { ...
Read more

python - NameError: name 'subprocess' is not defined -

-
i'm trying make rng website: http://jamesdotcom.com/?p=417 . when run following code: captureimage = subprocess.popen( [ "fswebcam", "-r", "356x292", "-d", "/dev/video0", "static.jpg", "--skip", "10" ], stdout=devnull, stderr=devnull) captureimage.communicate() i following error message: nameerror: name 'subprocess' not defined what should do? thanks have imported first? import subprocess captureimage = subprocess.popen(["fswebcam", ...) subprocess included in python standard library since python 2.4. should not necessary install it.
Read more