170
}
171
if incomingFirstEventID > nextEventID {
173
>
executionState := r.mutableState.GetExecutionState()
174
>
return false, serviceerrors.NewRetryReplication(
175
>
outOfOrderDeliveryMessage,
176
>
executionInfo.NamespaceId,
177
>
executionInfo.WorkflowId,
178
>
executionState.RunId,
179
>
lastVersionHistoryItem.GetEventId(),
180
>
lastVersionHistoryItem.GetVersion(),
181
>
incomingFirstEventID,
182
>
incomingFirstEventVersion)
183
>
}
184
// task.getFirstEvent().GetEventId() == nextEventID
185
return true, nil