Skip to Content
Actions

Using SAP PI’s JMS Queue to Send Alerts via SMS

August 20, 2014 | 355 Views |
 alertscomponent based message alertingintegrationpi 7.31Process Integrationsap netweaversap netweaver process integration
Follow

Hi Guys,

This is my first Document so please let me know if I can improve on certain areas.

The reason for this document is that we had a requirement to send out an SMS when there is a problem/error with our critical interfaces. This is mainly for the support guys that monitor the system.

The problem was that we did not have a SMS server in our environment but we did have a service provider that we would send the data of the SMS to the service provider via HTTP_AAE and they would then send out the SMS.

After I built the interface I thought it would be a good idea to share the knowledge with everyone that wanted to use the same solutions.

Im only going to cover how to retrieve the messages from the JMS queue and how to convert them into XML.

System Details:

7.31 Single Stack Patch 11

These were my Steps:

     1. Component Based Alerts Setup:

Followed the below links to setup my Component Based Alerting.  All this does is it takes the ICO that you
created and produces errors if there were any. These Errors are stored in a JMS
queue on SAP PI.

http://scn.sap.com/community/pi-and-soa-middleware/blog/2013/03/27/alerting-on-aaeaex

http://scn.sap.com/community/pi-and-soa-middleware/blog/2012/03/25/michals-pi-tips-component-based-message-alerting

     2. ESR (Enterprise Service Builder) Objects:

    1. DataTypes(This is the structure of the JMS target Structure)

                Structure_01.PNG

   b. MessageTypes

   c. ServiceInterfaces

   d. .JavaMapping(The data Stores in the JMS queue is stored in JSON format)

e. package simpleJSONToXML;

    

  2. import
    java.io.BufferedReader;
  3. import java.io.FileInputStream;
  4. import
    java.io.IOException;
  5. import
    java.io.InputStream;
  6. import
    java.io.OutputStream;
  7. import
    java.io.StringReader;
  8. import
    java.util.regex.Pattern;
  10. import
    com.sap.aii.mapping.api.AbstractTransformation;
  11. import
    com.sap.aii.mapping.api.StreamTransformationException;
  12. import
    com.sap.aii.mapping.api.TransformationInput;
  13. import
    com.sap.aii.mapping.api.TransformationOutput;
  15. public class SimpleJSONtoXMLextends
    AbstractTransformation
  17. {
  18.   private static final int CHUNK_SIZE = 10240;
  20.   public void
    transform(TransformationInput in, TransformationOutput out)
  21.    throws StreamTransformationException

  22. {
  23.    try
  24.   
    {
  25.     
    process(in.getInputPayload().getInputStream(),
    out.getOutputPayload().getOutputStream());
  26.   
    }
  27.    catch (IOException e)
  28.   
    {
  29.      throw new StreamTransformationException(“Error converting payload”, e);
  30.   
    }

  31. }
  33.   private void
    process(InputStream inputStream, OutputStream outputStream)
  34.    throws IOException

  35. {
  36.   
    String data = read(inputStream);
  37.   
    String xmlString = convertToXml(data);
  38.   
    outputStream.write(xmlString.getBytes());
  39.   
    outputStream.flush();
  40.   
    outputStream.close();

  41. }
  43.   private String
    convertToXml(String data)
  44.    throws IOException

  45. {
  46.   
    String newData = data.replaceAll(Pattern.quote(    “,”), “\r\n”);
  47.   
    String xml =     “<XmlRoot>\r\n”;
  48.   
    BufferedReader br =     new BufferedReader(new
    StringReader(newData));
  49.   
    String line =     “”;
  50.    while ((line = br.readLine()) != null) {
  51.     
    xml = xml + lineToTag(line);
  52.   
    }
  53.   
    br.close();
  54.   
    xml = xml +     “</XmlRoot>”;
  55.    return xml;

  56. }
  58.   private String
    lineToTag(String line)

  59. {
  60.    if (line.indexOf(‘:’) < 0) {
  61.      return “”;
  62.   
    }
  63.    if (line.indexOf(‘:’) > 12){
  64.   
         String[] parts =
    line.split(    “:”);
  65.   
    }
  67.   
    String[] parts = line.split(    “:”);
  68.    return createTag(getInnerField(parts[0].trim()),
    getInnerField(parts[1].trim()));

  69. }
  71.   private String
    createTag(String name, String value)

  72. {
  73.    return
  74.   
  76.      “<“ + name + “>” + value + “</” + name + “>\r\n”;

  77. }
  79.   private String
    getInnerField(String string)

  80. {
  81.    if ((string.startsWith(“\””)) &&
    (string.endsWith(    “\””))) {
  82.      return string.substring(1, string.length() – 1);
  83.   
    }
  84.    return string;

  85. }
  87.   private String
    read(InputStream inputStream)
  88.    throws IOException

  89. {
  90.    byte[] b = new byte[10240];
  91.   
  92.   
    String text =     “”;
  93.    int numBytesRead;
  94.    while ((numBytesRead = inputStream.read(b, 0, 10240)) > -1)
  95.   
    {
  96.     
    text = text +     new String(b, 0, numBytesRead);
  97.   
    }
  98.    return text;

  99. }
  101.   public static void main(String[]
    args)
  102.     throws IOException
  103.   {
  104.     String json = new
    SimpleJSONtoXML().read(    new FileInputStream(“test.txt”));
  105.     System.out.println(new
    SimpleJSONtoXML().convertToXml(json));
  106.   }
  107. }

e. Operational Mapping

  1. Configuration – Integration Builders Objects:
    1. Sender Channel (JMS)

                    Channel_01.PNG

      2. Receiver Channel (HTTP_AAE)

       3. ICO (Integrated Configuration)

  1. Additional Information:
    1. Source Message Payload

{               

“AdapterType”:”XI_J2EE_MESSAGING_SYSTEM”,

“Component”:””,

“ErrCat”:”XI_J2EE_ADAPTER_ENGINE”,

“ErrCode”:”CHANNEL_STOPPED”,

“ErrLabel”:”1402″,

“ErrText”:”Channel stopped by administrative task.”,

“FromParty”:””,

“FromService”:” _com_ “,

“Interface”:”ORDERS.ORDERS05.ORDERS05″,

“MonitoringUrl”:”http://webdynpro/resources/ “,

“MsgId”:”4cb299e3-196f-11e4-c7fa-0000007e49e2″,

“Namespace”: “urn:sap-com:document:sap:idoc:messages”,

“RuleId”:”d42a9af9fdc53609843f5a1d9f211911″,

“ScenarioId”:”dir://ICO/4bbe4a73043e3a3bbc0c23b35781c7ab”,

“Timestamp”:”2014-08-01T11:30:56Z”,

“ToParty”:””,

“ToService”:””

}

  1. Target Message Payload

<XmlRoot>

<AdapterType>XI_J2EE_MESSAGING_SYSTEM</AdapterType>

<Component>af.pd1.berlux21</Component>

<ErrCat>XI_J2EE_ADAPTER_ENGINE</ErrCat>

<ErrCode>CHANNEL_STOPPED</ErrCode>

<ErrLabel>1402</ErrLabel>

<ErrText>Channel
stopped by administrative task.</ErrText>

<FromParty></FromParty>

<FromService>barloworld_com_SAPECC_QAS</FromService>

<Interface>ORDERS.ORDERS05.ORDERS05</Interface>

<MonitoringUrl>”http</MonitoringUrl>

<MsgId>4cb299e3-196f-11e4-c7fa-0000007e49e2</MsgId>

<Namespace>”urn</Namespace>

<RuleId>d42a9af9fdc53609843f5a1d9f211911</RuleId>

<ScenarioId>”dir</ScenarioId>

<Timestamp>”2014-08-01T11</Timestamp>

<ToParty>DHL</ToParty>

<ToService>SQLServer</ToService>

</XmlRoot>

If there is anything you would like to know or advice me on then please dont hesitate to se me a message or comment. Thank you taking the time to read.

References :

http://scn.sap.com/community/pi-and-soa-middleware/blog/2013/03/27/alerting-on-aaeaex

http://scn.sap.com/community/pi-and-soa-middleware/blog/2012/03/25/michals-pi-tips-component-based-message-alerting

Regards,

Jannus

To report this post you need to login first.

5 Comments

You must be Logged on to comment or reply to a post.

    1. Jegatheeswaran Pitchaimuthu

      Hi Jannus,

      Thank you very much for the nice blog. I tried this. I was able to retrieve the alert from JMS queue and write it as an XML file in ftp. (by using your Java Mapping). Now, I have query.  To send this as a SMS, what are all the values (Service Provider details) I need to enter in the HTTP_AAE receiver channel. Could you please clarify?

      (0) 
      1. Jannus Botha Post author

        Hi,

        You would need to get the details from your service provider that you will use to send SMS’s through?

        For example. In the UK we use O2, Vodafone etc.

        They would normally give you an HTTPS end point where you will need to send your payload and they will then reformat that into there system and send the sms.

        Regards,

        Jannus Botha

        (0) 

Leave a Reply