Package | Description |
---|---|
psdi.iface.jms |
Modifier and Type | Method and Description |
---|---|
static JMSData |
MessageUtil.convertRecoveryDataToJMSData(java.lang.String filename,
boolean isCompress)
Reads saved JMSRecovery file and converts corrosponding JMS Data object.
|
static JMSData |
MessageUtil.createJMSData(javax.jms.Message msg) |
JMSData |
MessageErrorHandler.getCorrectedFile(JMSData data)
Return the appropriate data for the given incoming data.
|
JMSData |
MessageErrorHandler.getJMSData(java.util.Map<java.lang.String,java.lang.String> msgProperties)
Take in incoming file name and return back it's relevant JMS Data object
for further processing.
|
JMSData |
JMSConsumer.getMessage(boolean autocommit)
Get a message from the Queue matching the selection criterion [if a message selector
is specified].
|
Modifier and Type | Method and Description |
---|---|
java.util.List<JMSData> |
JMSQueueBrowser.getAllMessages() |
java.util.List<JMSData> |
JMSQueueBrowser.getMessages(int n) |
Modifier and Type | Method and Description |
---|---|
void |
JMSProducer.addMessage(JMSData data) |
static javax.jms.Message |
MessageUtil.createMessage(JMSData data,
javax.jms.Session session) |
void |
JMSMXTransactable.deleteMesage(JMSData messageData,
java.lang.String queueName,
UserInfo info) |
JMSData |
MessageErrorHandler.getCorrectedFile(JMSData data)
Return the appropriate data for the given incoming data.
|
void |
JMSProducer.sendMessage(JMSData data,
boolean autocommit)
Write a message to the Destination.
|
void |
JMSMXTransactable.storeMesage(java.lang.String status,
JMSData messageData,
java.lang.String queueName,
java.lang.Exception e,
UserInfo info) |
void |
MessageErrorHandler.success(JMSData data)
Perform necessary actions upon successful processing of the message.
|
Modifier and Type | Method and Description |
---|---|
void |
JMSProducer.sendMessage(java.util.List<JMSData> listData,
boolean autocommit)
Write a List of messages to the Destination.
|
void |
JMSMXTransactable.setMessages(java.util.Map<java.lang.String,JMSData> mapOfMessages) |