4 Replies Latest reply on Apr 10, 2009 10:05 PM by Chatura kalansooriya

    How to configure the usage of an inbound and outbound queue?

    Juha Siltanen Newbie

      I am trying to configure the following kind of a system:

      InboundQueue --> Action --> Action --> ... --> Action --> OutboundQueue

      In other words, one queue takes a message in and then it is passed through a pipeline of actions and finally ending up into a queue of ougoint message where the messages are beeing sent into the target system.

      I'm following the custom_action quickstart's example and managed to make my own queue and a few actions.

      How to configure the outgoing queue and how to pass the message from the action pipeline into that queue?

      Here is the jboss-esb.xml at the moment:

      <?xml version = "1.0" encoding = "UTF-8"?>
      <jbossesb xmlns="http://anonsvn.labs.jboss.com/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.0.1.xsd" parameterReloadSecs="5">
       <jms-provider name="JBossMessaging" connection-factory="ConnectionFactory">
       <jms-bus busid="IntegrationGWChannel">
       <jms-message-filter dest-type="QUEUE" dest-name="queue/Integration_GW"/>
       <jms-bus busid="IntegrationEsbChannel">
       <jms-message-filter dest-type="QUEUE" dest-name="queue/Integration_ESB"/>
       <service name="InboundActionService" description="Action pipeline for inbound messages" category="ActionServices">
       <jms-listener name="IntegrationGW" busidref="IntegrationGWChannel" is-gateway="true"></jms-listener>
       <jms-listener name="IntegrationEsb" busidref="IntegrationEsbChannel" is-gateway="false"></jms-listener>
       <actions mep="RequestResponse">
       <action name="firstAction" class="com.mycompany.InboundMessageLoggerAction" process="log">
       <property name="exceptionMethod" value="exceptionHandler" />
       <action name="secondAction" class="com.mycompany.InboundDataConversionAction" process="convert">
       <property name="exceptionMethod" value="exceptionHandler" />

      Thanks again! :-)