Skip to main content

WSO2 ESB quick reference - part II

In the first part of this blog post series, I have discussed about the fundamental things you should know when you are starting the WSO2 ESB. With this blog post, I am going to give you some quick references for configuring WSO2 ESB for different practical enterprise integration scenarios. I am using the WSO2 ESB documentation and various blog posts for preparing this blog post.

1. Message mediation

  • Log mediator can be used to check whether the message is actually passing through the ESB and the content of the message.
 <log level="full/> 

         If you need to print a custom log message with properties and custom messages, you can use log            mediator as below.

<log level="custom">
<!-- Printing a static text message -->
<property name="STATUS" value="Priting the status"/>
<!-- Printing a property saved in the message context -->
<property name="RESULT" expression="get-property('result')"/>
<!-- Printing a result of an xpath expression -->
<property name="RESPONSE_CODE" expression="\\ns:response\ns:code\text()"/>
</log>



  • If you need to route a message in to a web service which is located in a given address, you can use a send mediator with an address endpoint as below.
<send>
    <endpoint>
    </endpoint>
</send>

as an alternative method, you can use the header mediator to route the message to a given endpoint as below.

  • If you want to route a message to different end points according to the content of the message, you can use the switch mediator as below.
 <switch source="//m0:getQuote/m0:request/m0:type" xmlns:m0="http://services.samples">
    <case regex="Credit">
       <send>
         <endpoint>
           <address uri="http://localhost:9000/services/CreditService"/>
         </endpoint>
       </send>            
     </case>
     <case regex="Debit">
       <send>
         <endpoint>
           <address uri="http://localhost:9000/services/DebitService"/>
         </endpoint>
       </send>
     </case>
     <default>
      <log level="custom"/>
        <property name="warning message"
                              expression="fn:concat('Wrong message type - ', //m0:getQuote/m0:request/m0:type)"
                              xmlns:m0="http://services.samples"/>
      </log>
      </default>
 </switch>


  • If you need to save the message payload in to a property such that it can be used in a later stage during the mediation processing, you can use enrich mediator as below.

<!-- Saving the entire message body in to a property -->

<enrich>

   <source type="body" clone="true"/>

   <target type="property" property="REQUEST_PAYLOAD"/>
 </enrich>


<!-- Saving a part of the message body in to a property -->
<enrich>
  <source xmlns:ns="http://org.apache.synapse/xsd"
          xmlns:m0="http://services.samples"
          clone="true"
          xpath="//m0:getQuote/m0:request/m0:symbol/text()"/>
   <target type="property" property="ORIGINAL_REQ"/>
</enrich>


  • If you need to transform the request message before going in to the back end server, you can use the payload factory mediator as below.
<payloadFactory>
     <format>
         <m:getQuote xmlns:m="http://services.samples">
              <m:request>
                   <m:symbol>$1</m:symbol>
               </m:request>
         </m:getQuote>
      </format>
      <args>
          <arg xmlns:m0="http://services.samples" expression="//m0:Code"/>
      </args>
 </payloadFactory>


  • If you need to convert a POX (REST) message in to SOAP message, you can use the following configuration.
<send>
    <endpoint>
      <address uri="http://localhost:9000/services/SimpleStockQuoteService" format="soap11"/>
    </endpoint>
</send>


  • If you need to send a binary file with the SOAP message, you can use MTOM or SwA optimizations to your SOAP request as below.
<!-- Sending for MTOM endpoint -->
<send>
   <endpoint>
       <address uri="http://localhost:9000/services/MTOMSwASampleService" optimize="mtom"/>
    </endpoint>
 </send>

<!-- Sending for SwA endpoint -->

<send>

    <endpoint>

       <address uri="http://localhost:9000/services/MTOMSwASampleService" optimize="swa"/>

     </endpoint>
</send>



2. Proxy services

  • If you need to switch a message from SOAP to POX(REST), you can use the following configuration in the endpoint definition.

<endpoint>
   <address uri="http://localhost:9000/services/SimpleStockQuoteService" format="pox"/>
</endpoint>


  • You can use the following endpoint configuration to achieve dual channel invocation with in the WSO2 ESB
<endpoint>
    <enableAddressing separateListener="true"/>
    </address>
</endpoint>

  • Service chaining can be achieved from specifying the receiving sequence within the send mediator as below. You will get the response from the first service call in to the second (receiving) sequence.
<send receive="SimpleServiceSeq">
   <endpoint>
      <address uri="http://localhost:9000/services/SecureStockQuoteService"/>         </endpoint>
</send>

  • If you need to remove the security header of a request message, you can use the following configuration to send the message to a non-secured endpoint.
 <header name="wsse:Security" action="remove"
  <send>
    <endpoint>
    </endpoint>
  </send>

Comments

Popular posts from this blog

Understanding Threads created in WSO2 ESB

WSO2 ESB is an asynchronous high performing messaging engine which uses Java NIO technology for its internal implementations. You can find more information about the implementation details about the WSO2 ESB’s high performing http transport known as Pass-Through Transport (PTT) from the links given below. [1] http://soatutorials.blogspot.com/2015/05/understanding-wso2-esb-pass-through.html [2] http://wso2.com/library/articles/2013/12/demystifying-wso2-esb-pass-through-transport-part-i/ From this tutorial, I am going to discuss about various threads created when you start the ESB and start processing requests with that. This would help you to troubleshoot critical ESB server issues with the usage of a thread dump. You can monitor the threads created by using a monitoring tool like Jconsole or java mission control (java 1.7.40 upwards). Given below is a list of important threads and their stack traces from an active ESB server.  PassThroughHTTPSSender ( 1 Thread )

WSO2 ESB tuning performance with threads

I have written several blog posts explaining the internal behavior of the ESB and the threads created inside ESB. With this post, I am talking about the effect of threads in the WSO2 ESB and how to tune up threads for optimal performance. You can refer [1] and [2] to understand the threads created within the ESB. [1] http://soatutorials.blogspot.com/2015/05/understanding-threads-created-in-wso2.html [2] http://wso2.com/library/articles/2012/03/importance-performance-wso2-esb-handles-nonobvious/ Within this blog post, I am discussing about the "worker threads" which are used for processing the data within the WSO2 ESB. There are 2 types of worker threads created when you start sending the requests to the server 1) Server Worker/Client Worker Threads 2) Mediator Worker (Synapse-Worker) Threads Server Worker/Client Worker Threads These set of threads will be used to process all the requests/responses coming to the ESB server. ServerWorker Threads will be used to pr

How to configure timeouts in WSO2 ESB to get rid of client timeout errors

WSO2 ESB has defined some configuration parameters which controls the timeout of a particular request which is going out of ESB. In a particular  scneario, your client sends a request to ESB, and then ESB sends a request to another endpoint to serve the request. CLIENT->WSO2 ESB->BACKEND The reason for clients getting timeout is that ESB timeout is larger than client's timeout. This can be solved by either increasing the timeout at client side or by decreasing the timeout in ESB side. In any of the case, you can control the timeout in ESB using the below properties. 1) Global timeout defined in synapse.properties (ESB_HOME\repository\conf\) file. This will decide the maximum time that a callback is waiting in the ESB for a response for a particular request. If ESB does not get any response from Back End, it will drop the message and clears out the call back. This is a global level parameter which affects all the endpoints configured in ESB. synapse.global_timeout_inte