Skip to content

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[])
      );
   }
}