errorManager.resolveError¶
Signature: errorManager.resolveError(messageId, messageModel*)
Returns: void
Resolves the error and re-processes the original message or the optional messageModel associated with the messageId.
Parameters¶
| Type | Name | Description | Default |
|---|---|---|---|
| Long | messageId | the message ID for the error to resolve | |
| Message or byte[] | messageModel* | (optional) modified message | null |
Example¶
// From a Scheduled Script: retry processing errors that match a search
// Example: Resolve errors and reprocess messages
// From a Scheduled Script: retry processing errors that match a search
if (qie.getErrorCount() > 0) {
var results = errorManager.searchErrors("error=timeout");
for (var i = 0; i < results.size(); i++) {
var messageQueueId = results.get(i);
// Example: resolve using original message
errorManager.resolveError(
messageQueueId // messageId - ID of the errored message
);
// Example: resolve using modified message (Message object)
var sourceMessage = errorManager.getSource(messageQueueId);
sourceMessage.setNode("PID-33.1", "Good Value");
errorManager.resolveError(
messageQueueId, // messageId
sourceMessage // messageModel (Message)
);
// Example: resolve using modified message as byte[]
var modifiedBytes = sourceMessage.getEncodedBytes();
errorManager.resolveError(
messageQueueId, // messageId
modifiedBytes // messageModel (byte[])
);
}
}