psdi.iface.jms

Class MEAQueueProcessor

java.lang.Object

psdi.iface.jms.MEAQueueProcessor

public class MEAQueueProcessor
extends java.lang.Object

The handshake class to be called from Mic framework.

Field Summary

Fields

Modifier and Type	Field and Description
protected static MXLogger	integrationLogger Integration Logger

Constructor Summary

Constructors

Constructor and Description
MEAQueueProcessor()

Method Summary

Modifier and Type	Method and Description
void	closeQueueTX(java.lang.Object producer)
void	commitQueueTX(java.lang.Object producer)
void	rollbackQueueTX(java.lang.Object producer)
java.lang.Object	startQueueTX(java.lang.String queueName)
void	writeDataToQueue(MXTransaction mxtran, java.lang.String sender, java.util.Map finalData, boolean isEvent, UserInfo userInfo)
void	writeDataToQueue(MXTransaction mxtran, java.lang.String sender, java.util.Map finalData, UserInfo userInfo)
void	writeDataToQueueIn(byte[] data, java.util.Map properties)
void	writeDataToQueueIn(byte[] data, java.util.Map properties, boolean compress)
void	writeDataToQueueIn(byte[] data, java.lang.String sender, java.lang.String ifaceName)
void	writeDataToQueueIn(byte[] data, java.lang.String sender, java.lang.String ifaceName, java.lang.String loginId)
void	writeDataToQueueIn(java.lang.Object queueProducer, byte[] data, java.lang.String sender, java.lang.String ifaceName, java.lang.String loginId)
boolean	writeToMessageProvider(byte[] extData, java.util.Map properties, java.lang.String kafkatopic, java.lang.String kafkaprovider, boolean compress, java.util.List msgTrackedList)
boolean	writeToMessageProviderTX(MessageHubProducer kProducer, byte[] extData, java.util.Map properties, java.lang.String kafkatopic, boolean compress, java.util.List msgTrackedList)
void	writeToQueue(byte[] extData, java.util.Map properties, java.lang.String queueName)
void	writeToQueue(byte[] extData, java.util.Map properties, java.lang.String queueName, boolean compress)
void	writeToQueueTX(java.lang.Object queueProducer, byte[] extData, java.util.Map properties, java.lang.String queueName)

Methods inherited from class java.lang.Object

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

Field Detail

integrationLogger

protected static final MXLogger integrationLogger

Integration Logger

Constructor Detail

MEAQueueProcessor

public MEAQueueProcessor()

Method Detail

writeDataToQueue

public void writeDataToQueue(MXTransaction mxtran,
                             java.lang.String sender,
                             java.util.Map finalData,
                             UserInfo userInfo)
                      throws MXException

Throws:

MXException

writeDataToQueue

public void writeDataToQueue(MXTransaction mxtran,
                             java.lang.String sender,
                             java.util.Map finalData,
                             boolean isEvent,
                             UserInfo userInfo)
                      throws MXException

Throws:

MXException

writeDataToQueueIn

public void writeDataToQueueIn(byte[] data,
                               java.util.Map properties,
                               boolean compress)
                        throws MXException

Throws:

MXException

writeDataToQueueIn

public void writeDataToQueueIn(byte[] data,
                               java.lang.String sender,
                               java.lang.String ifaceName)
                        throws MXException

Throws:

MXException

writeDataToQueueIn

public void writeDataToQueueIn(byte[] data,
                               java.lang.String sender,
                               java.lang.String ifaceName,
                               java.lang.String loginId)
                        throws MXException

Throws:

MXException

writeDataToQueueIn

public void writeDataToQueueIn(java.lang.Object queueProducer,
                               byte[] data,
                               java.lang.String sender,
                               java.lang.String ifaceName,
                               java.lang.String loginId)
                        throws MXException

Throws:

MXException

writeDataToQueueIn

public void writeDataToQueueIn(byte[] data,
                               java.util.Map properties)
                        throws MXException

Throws:

MXException

writeToMessageProvider

public boolean writeToMessageProvider(byte[] extData,
                                      java.util.Map properties,
                                      java.lang.String kafkatopic,
                                      java.lang.String kafkaprovider,
                                      boolean compress,
                                      java.util.List msgTrackedList)
                               throws MXException,
                                      java.io.IOException

Throws:

MXException

java.io.IOException

writeToMessageProviderTX

public boolean writeToMessageProviderTX(MessageHubProducer kProducer,
                                        byte[] extData,
                                        java.util.Map properties,
                                        java.lang.String kafkatopic,
                                        boolean compress,
                                        java.util.List msgTrackedList)
                                 throws MXException,
                                        java.io.IOException

Throws:

MXException

java.io.IOException

writeToQueue

public void writeToQueue(byte[] extData,
                         java.util.Map properties,
                         java.lang.String queueName)
                  throws MXException

Throws:

MXException

writeToQueueTX

public void writeToQueueTX(java.lang.Object queueProducer,
                           byte[] extData,
                           java.util.Map properties,
                           java.lang.String queueName)
                    throws MXException

Throws:

MXException

writeToQueue

public void writeToQueue(byte[] extData,
                         java.util.Map properties,
                         java.lang.String queueName,
                         boolean compress)
                  throws MXException

Throws:

MXException

startQueueTX

public java.lang.Object startQueueTX(java.lang.String queueName)
                              throws MXException

Throws:

MXException

commitQueueTX

public void commitQueueTX(java.lang.Object producer)

rollbackQueueTX

public void rollbackQueueTX(java.lang.Object producer)

closeQueueTX

public void closeQueueTX(java.lang.Object producer)