Uses of Class
com.onenetwork.platform.grid.TaskResult
Package | Description |
---|---|
com.onenetwork.platform.grid |
Interface into One Network's Computational Grid for parallel, dependency-aware task execution.
|
com.onenetwork.platform.integ.fixlen |
Service for parsing "fixed-length format" files, i.e.
|
com.onenetwork.platform.integ.msg |
APIs for using Platform's message queuing system.
|
-
Uses of TaskResult in com.onenetwork.platform.grid
Fields in com.onenetwork.platform.grid declared as TaskResult Modifier and Type Field Description static TaskResult
TaskResult. FAIL
Indicates failed execution without recording a failure reason.static TaskResult
TaskResult. RETRY
Indicates failed execution with desired retry, without recording a failure reason.static TaskResult
TaskResult. SUCCEED
Indicates successful execution without any need for recorded outputMethods in com.onenetwork.platform.grid that return TaskResult Modifier and Type Method Description static TaskResult
TaskResult. createFail(java.lang.String reason)
Create a fail result (with no retry), with a reason for the failure.static TaskResult
TaskResult. createFail(java.lang.String reason, java.lang.Throwable e)
Create a fail result (with no retry), with a reason and an exception.static TaskResult
TaskResult. createFail(java.lang.Throwable e)
Create a fail result (with no retry), with an exception.static TaskResult
TaskResult. createRetry(java.lang.String reason)
Create a retry result with a reason for the retry.static TaskResult
TaskResult. createRetry(java.lang.String reason, java.lang.Throwable e)
Create a retry result with a reason and an exception.static TaskResult
TaskResult. createRetry(java.lang.Throwable e)
Create a retry result with an exception.static TaskResult
TaskResult. createSucceed(java.lang.String output)
Create a successful result, attaching the specified output which will be written to the database and available asGridTask.getTaskResult()
.TaskResult
TaskPerformer. performTask(java.lang.String taskParams, java.lang.String taskInput)
Execute the given task - this represents the "meat" of most TaskPerformer implementations. -
Uses of TaskResult in com.onenetwork.platform.integ.fixlen
Methods in com.onenetwork.platform.integ.fixlen that return TaskResult Modifier and Type Method Description TaskResult
BaseInboundFixLenProcessor. process(Message message, GridTaskContext gridTaskContext, PlatformUserContext context)
Methods in com.onenetwork.platform.integ.fixlen with parameters of type TaskResult Modifier and Type Method Description void
BaseInboundFixLenProcessor. handleResults(TaskResult taskResult, Message message, PlatformUserContext context)
-
Uses of TaskResult in com.onenetwork.platform.integ.msg
Methods in com.onenetwork.platform.integ.msg that return TaskResult Modifier and Type Method Description TaskResult
InboundProcessingEvent. getTaskResult()
Returns theTaskResult
TaskResult
OutboundProcessingEvent. getTaskResult()
Returns theTaskResult
TaskResult
MessageHandler. onMessage(Message message, GridTaskContext ctx, PlatformUserContext context)
This method is called when the Message is ready for processingTaskResult
AbstractInboundProcessor. process(Message msg, GridTaskContext gridCtx, PlatformUserContext ctx)
TaskResult
InboundProcessor. process(Message message, GridTaskContext gridTaskContext, PlatformUserContext context)
Callback from the message queue framework to process an inbound message.TaskResult
MessageDestination. process(Message message, GridTaskContext ctx, PlatformUserContext context)
Process the outbound messageMethods in com.onenetwork.platform.integ.msg with parameters of type TaskResult Modifier and Type Method Description void
AbstractInboundProcessor. handleResults(TaskResult result, Message msg, PlatformUserContext ctx)
void
InboundProcessor. handleResults(TaskResult taskResult, Message message, PlatformUserContext context)
After processing, handles success and error cases, typically by enqueueing a response message.