Spring - JMS , after couple of start/stop of JMS activemq server, listener server throws java.io.EOFException and then does not connect to running JMS -

-

i have following setting in spring context file.

<bean id="amqpowerconnectionfactory" class="org.apache.activemq.activemqconnectionfactory">     <constructor-arg index="0" value="${power.messagebrokerurl}"/> </bean>  <bean id="powerconnectionfactory" class="org.springframework.jms.connection.cachingconnectionfactory">     <constructor-arg ref="amqpowerconnectionfactory"/> </bean>  <bean id="powereventqueue" class="org.apache.activemq.command.activemqqueue">     <constructor-arg value="powereventqueue"/> </bean>  <bean id="timeserieschangescontainer" class="org.springframework.jms.listener.defaultmessagelistenercontainer">     <property name="connectionfactory" ref="powerconnectionfactory"/>     <property name="destination" ref="powereventqueue"/>     <property name="messagelistener" ref="timeseriesdataadapter"/>     <property name="recoveryinterval" value="5000"/> </bean>  <bean id="timeseriesdataadapter" class="com.sungard.energy.aligne.aligneweb.assetmanagement.timeseriesmessageadapter">     <property name="queuename"><value>"powereventqueue"</value></property>     <property name="messagehandler"  ref="timeseriesmessagehandler"/> </bean>  <bean id="timeseriesmessagehandler" class="com.sungard.energy.aligne.aligneweb.assetmanagement.timeseriesmessagehandler"> </bean>

"${power.messagebrokerurl}" tcp://localhost:61616 i.e. jms activemq running locally on machine.

app server listening activemq jms, when jms goes down , app server shows following message, right since jms down , it's trying see if it's or not @ every 5 seconds.

    warn defaultmessagelistenercontainer:844 - setup of jms message listener invoker failed destination 'queue://powereventqueue' - trying recover. cause: *consumer* closed not refresh jms connection destination 'queue://powereventqueue' - retrying in 5000 ms. cause: not connect broker url: tcp://localhost:61616. reason: java.net.connectexception: connection refused: connect

now when restart jms, app server connects , shows following message.

info defaultmessagelistenercontainer:893 - refreshed jms connection warn cachingconnectionfactory:301 - encountered jmsexception - resetting underlying jms connection

now when take down jms server again appserver instead of showing connection refused shows following message.

warn defaultmessagelistenercontainer:844 - setup of jms message listener invoker failed destination 'queue://powereventqueue' - trying recover. cause: session closed info cachingconnectionfactory:291 - established shared jms connection: activemqconnection {id=id:ap-pun-ws0430-53381-1437557704588-0:28,clientid=null,started=false} error defaultmessagelistenercontainer:909 - not refresh jms connection destination 'queue://powereventqueue' - retrying in 1000 ms. cause: jms connection has failed: java.io.eofexception

and if start jms server, appserver not reconnect , continuously throws java.io.eofexception

on thing observed @ before successful reconnection jms, part of log message says , cause: consumer closed

where-as in other case says cause: session closed , following line

info cachingconnectionfactory:291 - established shared jms connection: activemqconnection {id=id:ap-pun-ws0430-53381-1437557704588-0:28,clientid=null,started=false}

value power.messagebrokerurl set 

power.messagebrokerurl=tcp://localhost:61616

if add failover in beginning of it, don' see error.

power.messagebrokerurl=failover:tcp://localhost:61616

update: above settings, listener server expected jms , running when starts. have add startupmaxreconnectattempts attribute values 1. default value -1 (i using activemq 5.5.0) signifies transport have no limit number of initial connection attempts , that's reason listener server not starting.

power.messagebrokerurl=failover:(tcp://localhost:61616)?startupmaxreconnectattempts=1

you can refer http://activemq.apache.org/failover-transport-reference.html transport options.


Comments

Post a Comment

Popular posts from this blog

Fail to load namespace Spring Security http://www.springframework.org/security/tags -

-
i have problem namespace of spring security on xhtml page. don't understand why can't load uri, , have following issue: whitelabel error page application has no explicit mapping /error, seeing fallback. tue jul 21 16:58:12 utc 2015 there unexpected error (type=not found, status=404). please need help! possible uri has been changed? best regards you using incorrect namespace url. correct url http://www.springframework.org/schema/security the error page seeing spring source website since not recognize url. try visiting http://www.springsource.org/security/tags in browser update : spring security tags used in jsp page correct tag lib declaration is: <%@ taglib prefix="sec" uri="http://www.springframework.org/security/tags" %>
Read more

sql - MySQL query optimization using coalesce -

-
can explain me why second query faster first? (first 1 takes around 40 seconds, second 1 less 0.1) select releases.feature_code, releases.platform_id, version, release_date, general_available, uri, filesize, display_name, feature_name.full_name, if ((select exists(select 1 release_exceptions releases.feature_code = release_exceptions.feature_code , releases.platform_id = release_exceptions.platform_id , releases.version = release_exceptions.version) = 1), 1, 0) release_exceptions releases left outer join platform using(platform_id) left outer join feature_name using(feature_code) order version desc; ~~~ query 2 ------------------ ~~~ select feature_code, version, release_date, general_available, platform_id, uri, filesize, display_name, feature_name.full_name, coalesce(release_exceptions, 0) release_exceptions mus.releases left outer join ( select distinct feature_code, version, platform_id, 1 release_exceptions mus.release_exceptions ) release_exceptions using ...
Read more

unity3d - Unity local avoidance in user created world -

-
i'm using unity3d networked multiplayer online game have large complex 3d terrain scene forest, trees, cliff, hills, mountains, bounders, etc. players can build structures sort of minecraft, , put them anywhere in scene, or move them around anytime. aside human controlled players, there automated ai players , objects animals roaming around scene following path. the problem how make these automated ai players , animals, able navigate around static , dynamic player created structures, because path follow can blocked player created structures, or other players , other ai objects, cliffs etc. have find away around them or on track if tumble down off high cliff example. so made navmesh , used navagents, takes care of static, non moving objects, how make ai players navigate around each other , dynamic structures created players can number in hundreds? i thought of adding navmeshobstacle everything, result in being attached hundreds of objects since user created structures b...
Read more