psdi.iface.jms

Class MessageUtil

java.lang.Object

psdi.iface.jms.MessageUtil

public class MessageUtil
extends java.lang.Object

A factory for creating JMSTxData objects.

Author:

Anamitra

Constructor Summary

Constructors

Constructor and Description
MessageUtil()

Method Summary

Modifier and Type	Method and Description
static byte[]	compressMessage(byte[] messageBody)
static org.jdom.Document	convertBytesToRecoveryData(byte[] data, java.util.Map msgProperties) Builds JMSRecovery message from incoming byte data
static JMSData	convertRecoveryDataToJMSData(java.lang.String filename, boolean isCompress) Reads saved JMSRecovery file and converts corrosponding JMS Data object.
static JMSData	createJMSData(javax.jms.Message msg)
static javax.jms.Message	createMessage(JMSData data, javax.jms.Session session)
static void	emailQueueError(QueueEmailInfo queueEmailInfo, java.lang.Exception t, java.lang.String errorMsgGroup, java.lang.String errorMsgKey, java.lang.String queueName) Email the incoming error having error file name info in the email.
static java.lang.String	generateUniqueID()
static java.lang.String	getJMSREcoveryFileName(java.util.Map msgProperties)
static java.util.Map<java.lang.String,java.lang.String>	getProperties(javax.jms.Message msg)
static QueueEmailInfo	getQueueEmailInfo(QueueConfig queueConfig)
static boolean	queueEmailToBeSent(java.util.Map msgProperties) Check if email needs to go out or it's already been sent depending upon if error file exists for a given queue or not
static byte[]	uncompressMessage(byte[] cdata, int uncompressedLength)

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageUtil

public MessageUtil()

Method Detail

generateUniqueID

public static java.lang.String generateUniqueID()

uncompressMessage

public static byte[] uncompressMessage(byte[] cdata,
                                       int uncompressedLength)
                                throws MXException

Throws:

MXException

compressMessage

public static byte[] compressMessage(byte[] messageBody)
                              throws MXException

Throws:

MXException

getProperties

public static java.util.Map<java.lang.String,java.lang.String> getProperties(javax.jms.Message msg)
                                                                      throws MXException

Throws:

MXException

createJMSData

public static JMSData createJMSData(javax.jms.Message msg)
                             throws MXException

Throws:

MXException

createMessage

public static javax.jms.Message createMessage(JMSData data,
                                              javax.jms.Session session)
                                       throws MXException

Throws:

MXException

getQueueEmailInfo

public static QueueEmailInfo getQueueEmailInfo(QueueConfig queueConfig)

queueEmailToBeSent

public static boolean queueEmailToBeSent(java.util.Map msgProperties)
                                  throws java.rmi.RemoteException,
                                         MXException

Check if email needs to go out or it's already been sent depending upon if error file exists for a given queue or not

Throws:

MXException

java.rmi.RemoteException

emailQueueError

public static void emailQueueError(QueueEmailInfo queueEmailInfo,
                                   java.lang.Exception t,
                                   java.lang.String errorMsgGroup,
                                   java.lang.String errorMsgKey,
                                   java.lang.String queueName)

Email the incoming error having error file name info in the email.

getJMSREcoveryFileName

public static java.lang.String getJMSREcoveryFileName(java.util.Map msgProperties)
                                               throws java.rmi.RemoteException,
                                                      MXException

Throws:

java.rmi.RemoteException

MXException

convertBytesToRecoveryData

public static org.jdom.Document convertBytesToRecoveryData(byte[] data,
                                                           java.util.Map msgProperties)
                                                    throws MXException,
                                                           java.rmi.RemoteException

Builds JMSRecovery message from incoming byte data

Throws:

MXException

java.rmi.RemoteException

convertRecoveryDataToJMSData

public static JMSData convertRecoveryDataToJMSData(java.lang.String filename,
                                                   boolean isCompress)
                                            throws MXException

Reads saved JMSRecovery file and converts corrosponding JMS Data object.

Throws:

MXException