psdi.iface.mic

Interface MessageTracker

  • All Known Implementing Classes:
    DBMsgTracker


    public interface MessageTracker
    Common interface to be implemented by specific Messgae Tracking implementations
    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method and Description
      boolean rollbackTrackingLog(java.lang.String messageId) 
      boolean trackMessage(java.util.Map properties)
      Perform Message Tracking with Implcite commit.
      boolean trackMessage(java.util.Map properties, byte[] data)
      Perform Message Tracking with Implcite commit.
      boolean trackMessage(java.util.Map properties, byte[] data, java.sql.Connection conn)
      Perform Message Tracking without commit.
      boolean trackMessage(java.util.Map properties, java.sql.Connection conn)
      Perform Message Tracking without commit.
    • Method Detail

      • trackMessage

        boolean trackMessage(java.util.Map properties,
                             byte[] data)
                      throws MXException
        Perform Message Tracking with Implcite commit. Typically needed by message producer in order to store original message data.
        Parameters:
        properties - Message Properties needed for tracking
        data - Original Message data
        Returns:
        true if Message was tracked. False would result when tracking is not enabled.
        Throws:
        MXException
      • trackMessage

        boolean trackMessage(java.util.Map properties)
                      throws MXException
        Perform Message Tracking with Implcite commit. Typically needed by message consumer to update the existing tracking info for a given message.
        Parameters:
        properties - Message Properties needed for tracking
        Returns:
        true if Message was tracked. False would result when tracking is not enabled.
        Throws:
        MXException
      • trackMessage

        boolean trackMessage(java.util.Map properties,
                             byte[] data,
                             java.sql.Connection conn)
                      throws MXException
        Perform Message Tracking without commit. It is the responsibility of client to commit An example would be file load when all messages are tracked as they are getting saved in JMS Queue and only one final commit is done at JMS transaction to ensure either all go in or none. Typically needed by message producer in order to store original message data when producer needs to perform commit itself.
        Parameters:
        properties - Message Properties needed for tracking
        data - Original Message data
        conn - Database connection to be used by tracking logic
        Returns:
        true if Message was tracked. False would result when tracking is not enabled.
        Throws:
        MXException
      • trackMessage

        boolean trackMessage(java.util.Map properties,
                             java.sql.Connection conn)
                      throws MXException
        Perform Message Tracking without commit. Typically needed by message consumer to update the existing tracking info for a given message and consumer assumes the commit resposibility. This method is called internally within the class and currently there is no good example of this where in application logic this might be needed.
        Parameters:
        properties - Message Properties needed for tracking
        conn - Database connection to be used by tracking logic
        Returns:
        true if Message was tracked. False would result when tracking is not enabled.
        Throws:
        MXException
      • rollbackTrackingLog

        boolean rollbackTrackingLog(java.lang.String messageId)
                             throws MXException
        Throws:
        MXException