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.

Constructor Summary

Constructors

Constructor and Description
MEAQueueProcessor()

Method Summary

Modifier and Type	Method and Description
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<java.lang.String,ExternalDataInfo> finalData, boolean isEvent, UserInfo userInfo)
void	writeDataToQueue(MXTransaction mxtran, java.lang.String sender, java.util.Map<java.lang.String,ExternalDataInfo> finalData, UserInfo userInfo)
void	writeDataToQueueIn(byte[] data, java.util.Map<java.lang.String,java.lang.String> properties)
void	writeDataToQueueIn(byte[] data, java.util.Map<java.lang.String,java.lang.String> 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<java.lang.String,java.lang.String> properties, java.lang.String kafkatopic, java.lang.String kafkaprovider, boolean compress)
boolean	writeToMessageProviderTX(MessageHubProducer kProducer, byte[] extData, java.util.Map<java.lang.String,java.lang.String> properties, java.lang.String kafkatopic, boolean compress)
void	writeToQueue(byte[] extData, java.util.Map<java.lang.String,java.lang.String> properties, java.lang.String queueName)
void	writeToQueue(byte[] extData, java.util.Map<java.lang.String,java.lang.String> properties, java.lang.String queueName, boolean compress)
void	writeToQueueTX(java.lang.Object queueProducer, byte[] extData, java.util.Map<java.lang.String,java.lang.String> properties, java.lang.String queueName)

Methods inherited from class java.lang.Object

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

Constructor Detail

MEAQueueProcessor

public MEAQueueProcessor()

Method Detail

writeDataToQueue

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

Throws:

MXException

writeDataToQueue

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

Throws:

MXException

writeDataToQueueIn

public void writeDataToQueueIn(byte[] data,
                               java.util.Map<java.lang.String,java.lang.String> 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<java.lang.String,java.lang.String> properties)
                        throws MXException

Throws:

MXException

writeToMessageProvider

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

Throws:

MXException

java.io.IOException

writeToMessageProviderTX

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

Throws:

MXException

java.io.IOException

writeToQueue

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

Throws:

MXException

writeToQueueTX

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

Throws:

MXException

writeToQueue

public void writeToQueue(byte[] extData,
                         java.util.Map<java.lang.String,java.lang.String> 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)