java - How to assign a service to message-driven-adapter in Spring Integration? -


upon received message in receivechannel invoke service work. flow of messages be: 

jms message -> receivechannel -- message-driven-adapter --> jmsinchannel -> queuechannel (here service should invoked)

i achieve either 1) service invoked on queuechannel 2) or message-adapater.

in latter case not know how assign service message-driven-adapter in spring integration? service not invoked.

this configuration contains both approaches none of them working:

<int-jms:channel id="receivechannel"      queue-name="forward"     connection-factory="connectionfactory"      auto-startup="true"> </int-jms:channel>  <si:channel id="jmsinchannel"/> <int-jms:message-driven-channel-adapter id="messagedrivenadapter"     channel="receivechannel" destination-name="jmsinchannel"/> <si:bridge input-channel="jmsinchannel" output-channel="queuechannel"/>   <si:channel id="queuechannel">     <si:queue/> </si:channel>    <si:service-activator id ="activator" ref="messageservice"      method="processmessage"      input-channel="queuechannel"> </si:service-activator>

and sender sends messages forward queue:

 <si:channel id="sendchannel"/> <int-jms:outbound-channel-adapter  connection-factory="connectionfactory"  destination-name="forward"  channel="sendchannel"/>  <si:gateway id="forwardgateway"      service-interface="com.ucware.ucpo.forward.jms.messagegateway"      default-request-channel="sendchannel"/>

messages coming forward queue in activemq backend.

update: added listener , messages received. log file trace turned on: 

18.07.2013 15:52:16.036 [directchannel] [abstractmessagechannel.java] [debug] [main] postsend (sent=true) on channel 'inputchannel', message: [payload={forward_all=3000, line=601}     [headers={timestamp=1374155536031, id=c2895e24-2260-4af8-9b23-a226ae95c31f,    source=presence_engine,userid=alice@tkb.local, type=forward}]  18.07.2013 15:52:16.036 [activemqmessageconsumer] [activemqmessageconsumer.java] [trace] [org.springframework.jms.listener.defaultmessagelistenercontainer#1-1] id:lmiroslaw-pc-59127-1374155535776-1:1:1:1 **received message: messagedispatch** {commandid = 0, responserequired = false, consumerid = id:lmiroslaw-pc-59127-1374155535776-1:1:1:1, destination = queue://forward, message = activemqobjectmessage {commandid = 11, responserequired = true, messageid = id:lmiroslaw-pc-59127-1374155535776-1:1:3:1:3, originaldestination = null, originaltransactionid = null, producerid = id:lmiroslaw-pc-59127-1374155535776-1:1:3:1, destination = queue://forward, transactionid = null, expiration = 0, timestamp = 1374155536032, arrival = 0, brokerintime = 1374155536013, brokerouttime = 1374155536013, correlationid = null, replyto = null, persistent = true, type = null, priority = 4, groupid = null, groupsequence = 0, targetconsumerid = null, compressed = false, userid = null, content = org.apache.activemq.util.bytesequence@1bc4ec8, marshalledproperties = org.apache.activemq.util.bytesequence@1d840d9, datastructure = null, redeliverycounter = 0, size = 0, properties = {timestamp=1374155536031, userid=alice@tkb.local, source=presence_engine, type=forward}, readonlyproperties = true, readonlybody = true, droppable = false}, redeliverycounter = 0}  18.07.2013 15:52:16.037 [defaultmessagelistenercontainer] [abstractpollingmessagelistenercontainer.java] [debug] [org.springframework.jms.listener.defaultmessagelistenercontainer#1-1] **received message of** type [class org.apache.activemq.command.activemqobjectmessage] consumer [cached jms messageconsumer: activemqmessageconsumer { value=id:lmiroslaw-pc-59127-1374155535776-1:1:1:1, started=true }] of session [cached jms session: activemqsession {id=id:lmiroslaw-pc-59127-1374155535776-1:1:1,started=true}]

<int-jms:channel/> not used start flow - it's providing message persistence mid-flow.

you don't need first 2 elements; configure message-driven adapter destination-name="forward" , receive messages queue.

also, remove queuechannel; it's not needed; service invoked on listener thread.

message-driven-adapter->jmsinchannel->service-activator


Comments

Post a Comment

Popular posts from this blog

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

Firefox SVG shape not printing when it has stroke -

Image
i having issue svg shapes have stroke , trying them print in firefox. this simplest example: <svg xmlns="http://www.w3.org/2000/svg" version="1.1" xmlns:xlink="http://www.w3.org/1999/xlink"> <rect x="0" y="0" rx="15" ry="15" width="300" height="400" style="stroke:black;stroke-width:5;" fill="black" /> <circle id="firstcircle" cx="50" cy="50" r="30" stroke="black" stroke-width="2" fill="white" style="opacity:0.75;"/> <circle id="secondcircle" cx="50" cy="150" r="30" fill="white" style="opacity:0.75;"/> </svg> when try , print first shape 1 of 2 things: it not show @ all it shows off center in bounding box. the second shape no stroke shows expected, expected. when displaying on scre...
Read more

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