java - Spring Integration Messages sent but not received with activeMQ -


i create simple test when messages sent / received forward queue. upon received message service should invoked.

unfortunately, messages sent through message<?> message = messagebuilder.withpayload(params); forwardgateway.sendpremmessage(message); not received.

this config: 

  <!-- sender -->  <si:gateway id="forwardgateway"      service-interface="com.ucware.ucpo.forward.jms.messagegateway"      default-request-channel="inputchannel"/>  <si:channel id="inputchannel"/>      <!-- subscriber channel --> <int-jms:outbound-channel-adapter  channel="inputchannel" connection-factory="connectionfactory"  destination-name="forward" />   <!-- receiver --> <int:channel id="jmsinchannel"/>   <!-- subscriber jmsinchannel. used instead of inboud channel adapter --> <int-jms:message-driven-channel-adapter id="messagedrivenadapter"     channel="jmsinchannel" destination-name="forward" connection-factory="connectionfactory"     concurrent-consumers="1" auto-startup="true" acknowledge="auto"/>   // service should invoked not  <si:service-activator id ="activator"      input-channel="jmsinchannel"     ref="messageservice"      method="process"/>

the service defined : 

@messageendpoint public class messageservice   {  public void process(message<?> message )

} , gateway :

public interface messagegateway  {  @gateway  public void sendpremmessage(message<?> message); }

your configuration works fine me; suggest turn on trace level logging see message flow on both sides. (trace gives details of message listener container activity on receiving side).

if using in-memory activemq need careful timing - don't send message until container has started. alternatively sure use cachingconnectionfactory.

<bean id="connectionfactory" class="org.springframework.jms.connection.cachingconnectionfactory">     <property name="targetconnectionfactory">         <bean class="org.apache.activemq.activemqconnectionfactory">             <property name="brokerurl" value="vm://localhost"/>         </bean>     </property> </bean>

that way, broker stay running after send, if container hasn't started yet.


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