psdi.iface.mic

Interface MessageTracker

All Known Implementing Classes:

DBMsgTracker

public interface MessageTracker

Common interface to be implemented by specific Messgae Tracking implementations

Author:

Nisha

Method Summary

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

Method Detail

trackMessage

boolean trackMessage(java.util.Map<java.lang.String,java.lang.String> 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<java.lang.String,java.lang.String> 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<java.lang.String,java.lang.String> 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<java.lang.String,java.lang.String> 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