psdi.iface.jms

Class JMSMXTransactable

java.lang.Object

psdi.iface.jms.JMSMXTransactable

All Implemented Interfaces:

java.rmi.Remote, Transactable

public class JMSMXTransactable
extends java.lang.Object
implements Transactable

The Transactable object for JMS. This participates in the Maximo transaction.

Author:

Anamitra

Constructor Summary

Constructors

Constructor and Description
JMSMXTransactable()

Method Summary

Methods

Modifier and Type	Method and Description
void	commitTransaction(MXTransaction txn) This method will be called during commit of the transaction
void	deleteMesage(JMSData messageData, java.lang.String queueName, UserInfo info)
void	fireEventsAfterDB(MXTransaction txn) fire events for all mbos in the transaction after db operation.
void	fireEventsAfterDBCommit(MXTransaction txn) fire events for all mbos in the transaction after db commit.
void	fireEventsBeforeDB(MXTransaction txn) fire events for all mbos in the transaction before db operation.
java.util.Map	getMessages()
boolean	isEvent()
void	rollbackTransaction(MXTransaction txn) This method will be called during rollback of the transaction
void	saveTransaction(MXTransaction txn) This method will be called during save of the transaction
boolean	sendEmail(QueueConfig config, java.sql.Connection conn, java.lang.Exception e) Select status and deleteflag to process message
void	setIsEvent(boolean isEvent)
void	setMessages(java.util.Map<java.lang.String,JMSData> mapOfMessages)
void	setUserInfo(UserInfo userInfo)
void	storeMesage(java.lang.String status, JMSData messageData, java.lang.String queueName, java.lang.Exception e, UserInfo info)
void	undoTransaction(MXTransaction txn) This method will be called during undo of the transaction
boolean	validateTransaction(MXTransaction txn) validate transaction.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JMSMXTransactable

public JMSMXTransactable()

Method Detail

setMessages

public void setMessages(java.util.Map<java.lang.String,JMSData> mapOfMessages)

setUserInfo

public void setUserInfo(UserInfo userInfo)

getMessages

public java.util.Map getMessages()

saveTransaction

public void saveTransaction(MXTransaction txn)
                     throws MXException,
                            java.rmi.RemoteException

This method will be called during save of the transaction

Specified by:

saveTransaction in interface Transactable

Parameters:

txn - Give reference to transaction object.

Throws:

MXException - MAXIMO exception

java.rmi.RemoteException - Remote exception

commitTransaction

public void commitTransaction(MXTransaction txn)
                       throws MXException,
                              java.rmi.RemoteException

This method will be called during commit of the transaction

Specified by:

commitTransaction in interface Transactable

Parameters:

txn - Give reference to transaction object.

Throws:

MXException - MAXIMO exception

java.rmi.RemoteException - Remote exception

rollbackTransaction

public void rollbackTransaction(MXTransaction txn)
                         throws MXException,
                                java.rmi.RemoteException

This method will be called during rollback of the transaction

Specified by:

rollbackTransaction in interface Transactable

Parameters:

txn - Give reference to transaction object.

Throws:

MXException - MAXIMO exception

java.rmi.RemoteException - Remote exception

undoTransaction

public void undoTransaction(MXTransaction txn)
                     throws MXException,
                            java.rmi.RemoteException

This method will be called during undo of the transaction

Specified by:

undoTransaction in interface Transactable

Parameters:

txn - reference to transaction object.

Throws:

MXException - MAXIMO exception

java.rmi.RemoteException - Remote exception

validateTransaction

public boolean validateTransaction(MXTransaction txn)
                            throws MXException,
                                   java.rmi.RemoteException

validate transaction.

Specified by:

validateTransaction in interface Transactable

Parameters:

txn - Transaction that caused the save

Throws:

MXException - Error while committing

java.rmi.RemoteException - Network error

fireEventsBeforeDB

public void fireEventsBeforeDB(MXTransaction txn)
                        throws MXException,
                               java.rmi.RemoteException

Description copied from interface: Transactable

fire events for all mbos in the transaction before db operation.

Specified by:

fireEventsBeforeDB in interface Transactable

Parameters:

txn - Transaction

Throws:

MXException - Error while committing

java.rmi.RemoteException - Network error

fireEventsAfterDB

public void fireEventsAfterDB(MXTransaction txn)
                       throws MXException,
                              java.rmi.RemoteException

Description copied from interface: Transactable

fire events for all mbos in the transaction after db operation.

Specified by:

fireEventsAfterDB in interface Transactable

Parameters:

txn - Transaction

Throws:

MXException - Error while committing

java.rmi.RemoteException - Network error

fireEventsAfterDBCommit

public void fireEventsAfterDBCommit(MXTransaction txn)
                             throws MXException,
                                    java.rmi.RemoteException

Description copied from interface: Transactable

fire events for all mbos in the transaction after db commit.

Specified by:

fireEventsAfterDBCommit in interface Transactable

Parameters:

txn - Transaction

Throws:

MXException - Error while committing

java.rmi.RemoteException - Network error

isEvent

public boolean isEvent()

setIsEvent

public void setIsEvent(boolean isEvent)

storeMesage

public void storeMesage(java.lang.String status,
               JMSData messageData,
               java.lang.String queueName,
               java.lang.Exception e,
               UserInfo info)
                 throws MXException

Throws:

MXException

deleteMesage

public void deleteMesage(JMSData messageData,
                java.lang.String queueName,
                UserInfo info)
                  throws MXException

Throws:

MXException

sendEmail

public boolean sendEmail(QueueConfig config,
                java.sql.Connection conn,
                java.lang.Exception e)
                  throws MXException

Select status and deleteflag to process message

Parameters:

proprties - map of all message properties

Returns:

0 for process 1 for delete 2 for rollback

Throws:

MXException - MAXIMO exception