public class SendTransactedMsgCmdImpl extends ControllerCommandImpl implements SendTransactedMsgCmd
Modifier and Type | Field and Description |
---|---|
static java.lang.String | COPYRIGHT
IBM copyright notice field.
|
Constructor and Description |
---|
SendTransactedMsgCmdImpl()
Constructs the SendTransactedMsg object by calling its parents constructor.
|
Modifier and Type | Method and Description |
---|---|
void | afterFail(java.lang.Long msg_id, java.lang.Integer tran_id, java.lang.Integer retries, java.sql.Timestamp expiry)
This method updates the message in the MSGSTORE table by decrementing the retries field by one.
|
void | afterFailCheckExpired(java.lang.Long msg_id, java.lang.Integer tran_id, java.lang.Integer retries, java.lang.String duration)
Checks whether the expiry field within the MSGSTORE table has expired.
|
void | afterSuccess(java.lang.Long msg_id, java.lang.Integer tran_id)
After the message is successfully sent, it will be removed from the MSGSTORE table.
|
void | afterSuccessKeepMessage(java.lang.Long msg_id, java.lang.Integer tran_id)
This method stores the content of each message into the MSGARCHIVE table
|
void | assembleMsg()
This method takes all messages from MsgStoreAccessBean with retries greater than 0 and attempts to send the messages.
|
int | findNextMsgIdIndex(java.util.LinkedList messageList)
Finds the index of the next message ID to send when the previous message cannot be found.
|
java.lang.Long[] | getResourceOwners()
This method returns the Organization unit reference numbers for all the resources accessed by this command.
|
java.util.LinkedList | listMessages(java.lang.Integer retriesGreaterThan)
Gets the next available message ID to send.
|
void | performExecute()
Assembles the messages in the MsgStoreAccessBean and sends the messages.
|
void | setRequestProperties(TypedProperty reqProperties)
This method sets the parameters that are passed to the command.
|
public static final java.lang.String COPYRIGHT
public SendTransactedMsgCmdImpl()
public void afterFail(java.lang.Long msg_id, java.lang.Integer tran_id, java.lang.Integer retries, java.sql.Timestamp expiry)
public void afterSuccess(java.lang.Long msg_id, java.lang.Integer tran_id)
public void afterSuccessKeepMessage(java.lang.Long msg_id, java.lang.Integer tran_id)
public void assembleMsg()
public java.lang.Long[] getResourceOwners() throws ECException
public void performExecute() throws ECException
public void afterFailCheckExpired(java.lang.Long msg_id, java.lang.Integer tran_id, java.lang.Integer retries, java.lang.String duration)
public java.util.LinkedList listMessages(java.lang.Integer retriesGreaterThan) throws java.lang.Exception
public int findNextMsgIdIndex(java.util.LinkedList messageList)
public void setRequestProperties(TypedProperty reqProperties) throws ECException