ABAP based Trex in XI: Proto

ABAP based Trex in XI: Proto: I recommend readers to go through the blog by Alessandro Guarneri The specified item was not found. before proceeding. These kinds of super monitors are often required in an integration landscape.Good news is that we can search messages based on the payload from SP15 via TREX in XI. Do we really need to wait until our servers are upgraded to SP15? Is there a way out to search without using RWB? I am very impatient. Is there any way to do it ASAP?

Yes. We can search the incoming or outgoing messages based on the payload.
*&———————————————————————**& Report  Z_PAYLOAD_MSGGUIID*&*&———————————————————————**&*&*&———————————————————————*REPORT  z_payload_msgguiid.*********************Data Declarations**********************************DATA persist TYPE REF TO cl_xms_persist.DATA xms_msg TYPE REF TO if_xms_message.DATA xmb_msg TYPE REF TO cl_xms_message_xmb.DATA content TYPE xstring.DATA content_string TYPE string.DATA :pid LIKE sxmspmast-pid.DATA vers LIKE sxmspmast-vers.DATA payload TYPE sxms_mmfpayloads.DATA wa_payload TYPE LINE OF sxms_mmfpayloads.DATA: ixmlfactory TYPE REF TO if_ixml,         iparser TYPE REF TO if_ixml_parser,         streamfactory TYPE REF TO if_ixml_stream_factory,         istream TYPE REF TO if_ixml_istream,         idocument TYPE REF TO if_ixml_document,         lv_xpath TYPE string,         root TYPE REF TO if_ixml_element,         el   TYPE REF TO if_ixml_element,         vl   TYPE string.DATA msg_tab1 TYPE sxmsmsgtab.DATA msg_tab TYPE sxmsmsgtab.DATA wa TYPE LINE OF sxmsmsgtab.DATA p_mesg LIKE sxmspmast-msgguid.DATA : range_tab  LIKE RANGE OF sxmspmast-msgguid,range_line LIKE LINE OF range_tab.PARAMETERS xpath TYPE text256 obligatory.PARAMETERS: xvalue TYPE text256 obligatory.PARAMETERS :p_stdt TYPE sy-datum obligatory.PARAMETERS :p_endt TYPE sy-datum obligatory.DATA : lt_pids  TYPE sxms_sel_options,lt_back_pids  TYPE sxms_tab_sxmspid,ls_back_pids  TYPE sxmspid,ls_pids  TYPE sxmsselopt.************************************************************************************Retrieve PipeLine Id’s************************************lt_back_pids = cl_xms_persist=>get_pid( cl_xms_persist=>co_back_pid ).LOOP AT lt_back_pids INTO ls_back_pids.  ls_pids-sign = ‘E’.  ls_pids-option = ‘EQ’.  ls_pids-low  = ls_back_pids.  APPEND ls_pids TO lt_pids.ENDLOOP.lt_back_pids = cl_xms_persist=>get_pid( cl_xms_persist=>co_pe_pid ).LOOP AT lt_back_pids INTO ls_back_pids.  ls_pids-sign = ‘E’.  ls_pids-option = ‘EQ’.  ls_pids-low  = ls_back_pids.  APPEND ls_pids TO lt_pids.ENDLOOP.*****************************************************************************Fetch all Messages in the given data Ranges******************CALL FUNCTION ‘SXMB_SELECT_MESSAGES’  EXPORTING    im_exedate  = p_stdt    im_exe2date = p_endt    im_client   = sy-mandt    im_number   = 2147483647  IMPORTING    ex_msgtab   = msg_tab1.*****************************************************************************Fetch all versions of messages********************************LOOP AT msg_tab1 INTO wa.SELECT * FROM sxmspvers APPENDING CORRESPONDING FIELDS OF TABLE msg_tabWHERE msgguid = wa-msgguid.ENDLOOP.***********************************************************************CREATE OBJECT persist.*********Filter the messages for the XPATH given***********************LOOP AT msg_tab INTO wa.  CLEAR :content,p_mesg,pid,vers.  CLEAR payload[].  FREE xms_msg.  FREE xmb_msg.  p_mesg = wa-msgguid .  pid = wa-pid.  vers = wa-vers.  CALL METHOD persist->read_msg_all    EXPORTING      im_msgguid = p_mesg      im_pid     = pid      im_version = vers    IMPORTING      ex_message = xms_msg.  xms_msg->deleteheaderbyname(         nsuri  = if_xms_run_time_env=>co_nsuri         lcname = if_xms_run_time_env=>co_lcname ).  xmb_msg ?= xms_msg.  CALL METHOD xmb_msg->if_xms_message_xmb~get_main_payloads    RECEIVING      return = payload.  READ TABLE payload INTO wa_payload INDEX 1.  CALL METHOD wa_payload-mainpayload->getbinarycontent    RECEIVING      return = content.  IF NOT content IS INITIAL.*  Create DOM    TYPE-POOLS: ixml.    CLASS cl_ixml DEFINITION LOAD.    ixmlfactory = cl_ixml=>create( ).    streamfactory = ixmlfactory->create_stream_factory( ).    istream = streamfactory->create_istream_xstring( content ).    idocument = ixmlfactory->create_document( ).    iparser = ixmlfactory->create_parser( stream_factory =    streamfactory                                          istream = istream                                          document = idocument ).    iparser->parse( ).*       Search for xpath / value    lv_xpath = xpath.    root = idocument->get_root_element( ).    el   = root->find_from_path( path = lv_xpath ).    IF NOT el IS BOUND.*         Element not found, so delete message      wa-gen_entry = ‘X’.      MODIFY msg_tab FROM wa.    ELSE.      vl = el->get_value( ).      IF vl NE xvalue.*           Value doesn’t match, so delete message        wa-gen_entry = ‘X’.        MODIFY msg_tab FROM wa.      ENDIF.    ENDIF.  ELSE.    wa-gen_entry = ‘X’.    MODIFY msg_tab FROM wa.  ENDIF.  IF wa-gen_entry NE ‘X’.    range_line-sign   = ‘I’.    range_line-option = ‘EQ’.    range_line-low    = wa-msgguid.    APPEND range_line TO range_tab.  ENDIF.ENDLOOP.DELETE  msg_tab WHERE gen_entry = ‘X’.DESCRIBE TABLE msg_tab.SUBMIT rsxmb_select_messages                     WITH msgguid IN range_tab                     WITH lines = sy-tfill                     AND RETURN.
Just give the XPATH and XVALUE for searching the messages based on payload as explained in Alessandro’s blog. Additionally we need to provide start and end dates to select the messages for avoiding performance overhead.

Usage

I don’t delve into the details for creating this report as any ABAP’er should be able to do it.
Sample Snapshots:
Inbound Message:
XML Format:

I need to search the inbound messages where the Age1 equals dsf10 within a week.
Input Parameters for the Report:

Outbound Message:
XML Format:

I need to search the inbound messages where the Flag equals dsf10 within a week.
Input Parameters for the Report:

Ahhhhhhhh! I am able to search the messages in XI based on payload content using this report and the blog is the result of a challenge by Alessandro who provoked me for writing this one here. I definitely need to thank him for that.

Point to Note: Report is tested in my system and it works excellently for me. It is just a prototype and whoever so using the report can customize and enhance it to address the specific needs of the project. Report can be tuned for its performance for better results.