java - Spring MQ JMS reconnect configuration -


first have question on how configure jms mq reconnect application when broker connection shutdown , restarted.

below tried,

this configuration had in spring-mq-jms-connections.xml

<!-- spring jms queue connection factory -->         <!--         <bean id="jmsqueueconnectionfactory.7"             class="org.springframework.jms.connection.singleconnectionfactory"  >             <property name="targetconnectionfactory">                 <ref bean="internaljmsqueueconnectionfactory.7"/>             </property>         </bean> -->

i replaced below configuration introduced "defaultmessagelistenercontainer" wrap "singleconnectionfactory". 

<bean id="jmsqueueconnectionfactory.7" class="org.springframework.jms.listener.defaultmessagelistenercontainer">         <property name="connectionfactory">             <ref bean="single.connection.factory.7"/>         </property>          <property name="recoveryinterval" value="5000"/>      </bean>      <bean id="single.connection.factory.7" class="org.springframework.jms.connection.singleconnectionfactory">     <property name="targetconnectionfactory">         <ref bean="internaljmsqueueconnectionfactory.7"/>     </property>     </bean>

but started getting below exception after configuration change.

failed configure emapi: org.springframework.beans.factory.beancreationexception: error creating bean name 'senderagent.7' defined in url  [file://localhost/home/qos/qosdata/config/general/emapi/spring-mq-jms-connections.xml]:  cannot resolve reference bean 'jmsqueuetemplate.7' while setting bean property 'jmstemplate'; nested exception org.springframework.beans.factory.beancreationexception: error creating bean  name 'jmsqueuetemplate.7' defined in url  [file://localhost/home/qos/qosdata/config/general/emapi/spring-mq-jms-connections.xml]:  cannot resolve reference bean 'jmsqueueconnectionfactory.7' while setting bean property 'connectionfactory';  nested exception org.springframework.beans.factory.beancreationexception: error creating bean name  'jmsqueueconnectionfactory.7' defined in url [file://localhost/home/qos/qosdata/config/general/emapi/spring-mq-jms-connections.xml]:  invocation of init method failed; nested exception java.lang.illegalargumentexception:  property 'destination' or 'destinationname' required         @ org.springframework.beans.factory.support.beandefinitionvalueresolver.resolvereference(beandefinitionvalueresolver.java:275)         @ org.springframework.beans.factory.support.beandefinitionvalueresolver.resolvevalueifnecessary(beandefinitionvalueresolver.java:104)         @ org.springframework.beans.factory.support.abstractautowirecapablebeanfactory.applypropertyvalues(abstractautowirecapablebeanfactory.java:1244)         @ org.springframework.beans.factory.support.abstractautowirecapablebeanfactory.populatebean(abstractautowirecapablebeanfactory.java:1008)         @ org.springframework.beans.factory.support.abstractautowirecapablebeanfactory.docreatebean(abstractautowirecapablebeanfactory.java:470)         @ org.springframework.beans.factory.support.abstractautowirecapablebeanfactory$1.run(abstractautowirecapablebeanfactory.java:409)         @ java.security.accesscontroller.doprivileged(native method)

it says 'destination' or 'destinationname' required, dealing legacy code, not sure or doing right thing when changed configuration.

please suggest if there better way reconnect openmq application when broker connection goes down due exception or when restarted. looked @ spring jms connection factory exception listener, couldnt figure out.

a defaultmessagelistenercontainer listener container (used receive messages broker), not connection factory.

if using vehicle reconnect, needs dummy queue "listen" to.

edit: updated in response comment below.

consider using spring integration; can configured automatically fail over; like

<int:gateway service interface="foo.bar" default-request-channel="foo" />  <int:channel id="foo">     <int:dispatcher load-balancer="false"/> <int:channel/>  <int-jms:outbound-channel-adapter channel="foo" order="1" ... />  <int-file:outbound-channel-adapter channel="foo" order="2" mode="append" ... />

by default, dispatcher load balance (round robin) 2 adapters turning off load balancing send jms , fail on file.

spring integration has lots of features error handling, adding retry advice adapter etc, etc.

if don't want use spring integration, can like...

try {     this.jmstemplate.send(...); } catch (exception e) {     writetofile(...); }

Comments

Post a Comment

Popular posts from this blog

How to mention the localhost in android -

i trying call localhost in android application. unfortunately not possible used several methods emulator local host http://10.0.2.2/android/dbconnection.php and network ip address http://192.168.1.xx/android/dbconnection.php also http://localhost:8080/android/dbconnection.php but nothing connected localhost. purpose refer stackoverflow answers not working i facing same problem when worked on localhost. referred stackoverflow answer got solution create new emulator works fine in new emulator.
Read more

php - Calling a template part from a post -

i include iframe within post in wordpress. located inside content of post, meaning cannot in post template file, otherwise either before or after. i'd add facebook plugin within posts: <div id="socialwrap"><div class="fb-like" data-href="http://onlinearizonahomes.info" data-send="true" data-width="450" data-show-faces="true" data-font="arial"></div></div> i thinking of calling template part within post <?php get_template_part( 'social' ); ?> cannot use php within post without plugin (i'd avoid using plugin this). an alternative using javascript create html in post, seems unnecessary use of javascript. what best way add html within wordpress post? you can use shortcode. add functions.php function cudjex_fbshare( $atts, $content = null ) { global $post; $link = get_permalink($post->id); return '<div id="socialwrap...
Read more

c# - String.format() DateTime With Arabic culture -

check below code snippet, namespace testdateconvertion { class program { static void main(string[] args) { datetime testvalue = new datetime(2013, 12, 15, 15, 33, 44); cultureinfo culture = new cultureinfo("ar-sa"); string stringvalue = string.format(culture, "{0:d} {0:hh:mm:ss}", testvalue); console.writeline(stringvalue); console.readline(); } } } it gives output 22/02/35 15:33:44 i not getting how possible. whats 35 doing in output there that's 13/12/2015 in hijri, 35 means 1435 in hijri, default date format saudi arabia.
Read more