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

How to protect your APIs with self contained access token (JWT) using WSO2 API Manager and WSO2 Identity Server

In a typical enterprise information system, there is a high chance that people will use different types of systems built by different vendors to implement certain types of functionalities. The APIs might be hosted in an API Manager developed by vendor A and the user management can be implemented using a different vendor (vendor B). In this type of a situation, one system will not be able to directly contact the other system but they want to use both systems in tandem. Self-contained access tokens are used in these types of situations where applications can get the token from one system and use that in another system to access protected resources. In this scenario, the second system does not need to make a contact to the first system over the network to validate the user information since the token is self-contained and it has relevant details about the user. This will improve the token processing time significantly since it completely removes the network interaction. The below fig...

WSO2 ESB creating a response for a "GET" request

When you are creating REST APIs with WSO2 ESB, you may need to send some response message back to the user when something goes wrong. In this kind of scenario, you can create a payload inside the ESB and send it back. For doing this, you can use the below configuration. <api xmlns=" http://ws.apache.org/ ns/synapse " name="LoopBackProxy" context="/loopback">    <resource methods="POST GET">       <inSequence>          <property name="NO_ENTITY_BODY" scope="axis2" action="remove"></property>          <log level="full"></log>          <payloadFactory media-type="xml">             <format>                <m:messageBeforeLoopBack xmlns:m=" http://services...

WSO2 ESB usage of get-property function

What are Properties? WSO2 has a huge set of mediators but property mediator is mostly used mediator for writing any proxy service or API. Property mediator is used to store any value or xml fragment temporarily during life cycle of a thread for any service or API. We can compare “Property” mediator with “Variable” in any other traditional programming languages (Like: C, C++, Java, .Net etc). There are few properties those are used/maintained by ESB itself and on the other hand few properties can be defined by users (programmers). In other words, we can say that properties can be define in below 2 categories: ESB Defined Properties User Defined Properties. These properties can be stored/defined in different scopes, like: Transport Synapse or Default Axis2 Registry System Operation Generally, these properties are read by get-properties() function. This function can be invoked with below 2 variations. get-property(String propertyName) get-property(String scop...