In the architecture of modern e-business applications (such as SOA), loosely coupled systems are becoming more and more important. Reliable messaging is one important technology for this type of system.
Reliable RPC is the EntireX implementation of a reliable messaging system. It combines EntireX RPC technology and persistence, which is implemented with units of work (UOWs).
Reliable RPC allows asynchronous calls ("fire and forget")
Reliable RPC is supported by most EntireX wrappers
Reliable RPC messages are stored in the Broker's persistent store until a server is available
Reliable RPC clients are able to request the status of the messages they have sent
Reliable RPC is used to send messages to a persisted Broker service. The
messages are described by an IDL program that contains only IN
parameters. The
client interface object and the server interface object are generated from this
IDL file, using the EntireX DCOM Wrapper.
Reliable RPC is enabled at runtime. The client has to set one of two different modes before issuing a reliable RPC request:
AUTO_COMMIT
CLIENT_COMMIT
While AUTO_COMMIT
commits each RPC message implicitly after sending it, a
series of RPC messages sent in a unit of work (UOW) can be committed or rolled
back explicitly using CLIENT_COMMIT
mode.
The server is implemented and configured in the same way as for normal RPC.
All methods for reliable RPC are available on the interface object. See Standard Wrapper Properties for details. The methods are
RPCService.Reliable
(put
and get
)
RPCService.ReliableCommit
RPCService.ReliableRollback
RPCService.MessageID
RPCService.get_StatusOfMessage
Create Broker object and interface object:
// DCOM Wrapper Object MAILClass mail; mail.Logon();
Disable reliable RPC:
mail.Reliable = mail.RELIABLE_OFF;
Enable reliable RPC with AUTO_COMMIT
or CLIENT_COMMIT
:
mail.Reliable = mail.RELIABLE_AUTO_COMMIT; mail.Reliable = mail.RELIABLE_CLIENT_COMMIT;
The first RPC message:
mail.SENDMAIL("mail receiver", "Subject 1", "Text 1");
Check the status: get the message ID first and use it to retrieve the status:
String messageID = mail.MessageID; String messageStatus = mail.get_StatusOfMessage(messageID); System.out.println("Status: " + messageStatus + ", id: " + messageID);
The second RPC message:
mail.SENDMAIL("mail receiver", "Subject 2", "Text 2");
Commit the two messages:
mail.ReliableCommit();
Check the status again for the same message ID:
messageStatus = mail.get_StatusOfMessage(messageID); System.out.println("Status: " + messageStatus + ", id: " + messageID);
The third RPC message.
mail.SENDMAIL("mail receiver", "Subject 3", "Text 3");
Check the status: get the new message ID and use it to retrieve the status:
messageID = mail.MessageID(); messageStatus = mail.get_StatusOfMessage(messageID); System.out.println("Status: " + messageStatus + ", id: " + messageID);
Roll back the third message and check status:
mail.ReliableRollback(); messageStatus = mail.getStatusOfMessage(messageID); System.out.println("Status: " + messageStatus + ", id: " + messageID); mail.logoff();
All program calls that are called in the same transaction
(CLIENT_COMMIT
) must be in the same IDL library.
It is not allowed to switch from CLIENT_COMMIT
to AUTO_COMMIT
in a
transaction.
Messages (IDL programs) must have only IN parameters.
Not applicable.
A Broker configuration with PSTORE
is recommended. This enables the Broker
to store the messages for more than one Broker session. These messages are
still available after Broker restart. The attributes
STORE
, PSTORE
,
and PSTORE-TYPE
in the Broker attribute file can
be used to configure this feature. The lifetime of the messages and the status
information can be configured with the attributes
UOW-DATA-LIFETIME
and
UOW-STATUS-LIFETIME
. Other attributes such as
MAX-MESSAGES-IN-UOW
,
MAX-UOWS
and
MAX-UOW-MESSAGE-LENGTH
may be used in addition
to configure the units of work. See Broker Attributes.
The result of the function RPCService.get_StatusOfMessage
depends on the configuration of the unit of work status lifetime in the EntireX
Broker configuration. If the status is not stored longer than the message, the
function returns the error code 00780305 (no matching UOW
found
).