Quintiq file version 2.0
|
#parent: #root
|
MethodOverride SetInboundMessageProcessed (
|
DSP_OperationMessage message,
|
DSP_ServiceCommitterBase local_committer
|
)
|
{
|
TextBody:
|
[*
|
org_state_seqnr := local_committer.StateSeqNr();
|
message.StateSeqNr( org_state_seqnr );
|
local_committer.StateSeqNr( org_state_seqnr + 1 );
|
|
message_cpy := Object::Duplicate( message ).astype( DSP_OperationMessage );
|
this.OutboundMasterQueue().AddLastMessage( &message_cpy );
|
|
// Determine whether we need to execute outbound, if not, flush the message queue.
|
if( not this.DetermineNeedExecuteOutbound() )
|
{
|
this.OutboundMasterQueue().Flush();
|
}
|
// Delete the inbound message queue.
|
message.Delete();
|
*]
|
}
|
