Class WorkloadProcessingServiceImpl

java.lang.Object

org.j7m.middleware.examples.workload.WorkloadProcessingServiceImpl

All Implemented Interfaces:

WorkloadProcessingService

public final class WorkloadProcessingServiceImpl
extends Object
implements WorkloadProcessingService

Thread-safe in-memory implementation of WorkloadProcessingService.

All state is local to this service instance and is guarded by the instance monitor. The implementation is intentionally small and demonstration-only.

Constructor Summary

Constructors

Constructor	Description
WorkloadProcessingServiceImpl()	Creates an empty workload-processing service.

Method Summary

Modifier and Type	Method	Description
LeaseResult	acquireLease(TaskHandle handle, String ownerId)	Acquires or renews an example lease.
String	adminStatus()	Returns a compact status line for demo/admin output.
boolean	cancel(TaskHandle handle)	Cancels a task.
Checkpoint	checkpoint(TaskHandle handle)	Creates and returns a task checkpoint.
boolean	completeWithFence(TaskHandle handle, long fencingToken)	Completes the task when the supplied fencing token is current.
WorkloadTaskProgress	progress(TaskHandle handle)	Reads task progress.
WorkloadTaskStatus	status(TaskHandle handle)	Reads task status.
TaskHandle	submitTask(String payload)	Submits one in-memory task.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

WorkloadProcessingServiceImpl

public WorkloadProcessingServiceImpl()

Creates an empty workload-processing service.

Method Details

submitTask

public TaskHandle submitTask(String payload)

Submits one in-memory task.

Specified by:

submitTask in interface WorkloadProcessingService

Parameters:

payload - task payload

Returns:

task handle

status

public WorkloadTaskStatus status(TaskHandle handle)

Reads task status.

Specified by:

status in interface WorkloadProcessingService

Parameters:

handle - task handle

Returns:

immutable status snapshot

progress

public WorkloadTaskProgress progress(TaskHandle handle)

Reads task progress.

Specified by:

progress in interface WorkloadProcessingService

Parameters:

handle - task handle

Returns:

immutable progress snapshot

checkpoint

public Checkpoint checkpoint(TaskHandle handle)

Creates and returns a task checkpoint.

Specified by:

checkpoint in interface WorkloadProcessingService

Parameters:

handle - task handle

Returns:

checkpoint metadata

cancel

public boolean cancel(TaskHandle handle)

Cancels a task.

Specified by:

cancel in interface WorkloadProcessingService

Parameters:

handle - task handle

Returns:

whether cancellation changed the task state

acquireLease

public LeaseResult acquireLease(TaskHandle handle,
 String ownerId)

Acquires or renews an example lease.

Specified by:

acquireLease in interface WorkloadProcessingService

Parameters:

handle - task handle

ownerId - owner identity

Returns:

lease result

completeWithFence

public boolean completeWithFence(TaskHandle handle,
 long fencingToken)

Completes the task when the supplied fencing token is current.

Specified by:

completeWithFence in interface WorkloadProcessingService

Parameters:

handle - task handle

fencingToken - caller fencing token

Returns:

whether the token was current and completion succeeded

adminStatus

public String adminStatus()

Returns a compact status line for demo/admin output.

Specified by:

adminStatus in interface WorkloadProcessingService

Returns:

safe status line