Class LoggingAccumulatorIIAR

java.lang.Object

com.scivicslab.pojoactor.core.ActorRef<com.scivicslab.pojoactor.core.accumulator.Accumulator>

com.scivicslab.pojoactor.workflow.IIActorRef<com.scivicslab.pojoactor.core.accumulator.Accumulator>

com.scivicslab.actoriac.LoggingAccumulatorIIAR

All Implemented Interfaces:

com.scivicslab.pojoactor.core.CallableByActionName, AutoCloseable

public class LoggingAccumulatorIIAR
extends com.scivicslab.pojoactor.workflow.IIActorRef<com.scivicslab.pojoactor.core.accumulator.Accumulator>

Accumulator actor reference that also logs to H2 database.

This class extends the standard accumulator functionality to also write logs to the H2LogStore for persistent storage. Each node's output is stored with the node ID for later querying.

Supported Actions

• add - Adds a result and logs to database
• getSummary - Returns formatted summary of all results
• getCount - Returns the number of added results
• clear - Clears all accumulated results

Since:

2.9.0

Author:

devteam@scivics-lab.com

Field Summary

Fields

Modifier and Type	Field	Description
private final Logger	logger
private final DistributedLogStore	logStore
private final long	sessionId

Fields inherited from class com.scivicslab.pojoactor.core.ActorRef

actorName, actorSystem, object

Constructor Summary

Constructors

Constructor	Description
LoggingAccumulatorIIAR(String actorName, com.scivicslab.pojoactor.core.accumulator.Accumulator object, com.scivicslab.pojoactor.workflow.IIActorSystem system, DistributedLogStore logStore, long sessionId)	Constructs a new LoggingAccumulatorIIAR.

Method Summary

Modifier and Type	Method	Description
com.scivicslab.pojoactor.core.ActionResult	callByActionName(String actionName, String arg)
private com.scivicslab.pojoactor.core.ActionResult	handleAdd(String arg)	Handles the add action.
private com.scivicslab.pojoactor.core.ActionResult	handleClear()	Handles the clear action.
private com.scivicslab.pojoactor.core.ActionResult	handleGetCount()	Handles the getCount action.
private com.scivicslab.pojoactor.core.ActionResult	handleGetSummary()	Handles the getSummary action.

Methods inherited from class com.scivicslab.pojoactor.core.ActorRef

ask, ask, askNow, clearJsonState, clearPendingMessages, close, createChild, getJsonBoolean, getJsonInt, getJsonString, getJsonString, getName, getNamesOfChildren, getParentName, hasJson, hasJsonState, initLogger, isAlive, json, putJson, setParentName, system, tell, tell, tellNow

Methods inherited from class Object

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

Field Details

logger

private final Logger logger

logStore

private final DistributedLogStore logStore

sessionId

private final long sessionId

Constructor Details

LoggingAccumulatorIIAR

public LoggingAccumulatorIIAR(String actorName,
 com.scivicslab.pojoactor.core.accumulator.Accumulator object,
 com.scivicslab.pojoactor.workflow.IIActorSystem system,
 DistributedLogStore logStore,
 long sessionId)

Constructs a new LoggingAccumulatorIIAR.

Parameters:

actorName - the name of this actor

object - the Accumulator implementation

system - the actor system

logStore - the distributed log store for database logging

sessionId - the session ID for this workflow execution

Method Details

callByActionName

public com.scivicslab.pojoactor.core.ActionResult callByActionName(String actionName,
 String arg)

Specified by:

callByActionName in interface com.scivicslab.pojoactor.core.CallableByActionName

Specified by:

callByActionName in class com.scivicslab.pojoactor.workflow.IIActorRef<com.scivicslab.pojoactor.core.accumulator.Accumulator>

handleAdd

private com.scivicslab.pojoactor.core.ActionResult handleAdd(String arg)
                                                      throws ExecutionException,
InterruptedException

Handles the add action.

Adds the result to the accumulator (for console output) and also logs to the H2 database for persistent storage.

Parameters:

arg - JSON object with source, type, and data fields

Returns:

ActionResult indicating success or failure

Throws:

ExecutionException

InterruptedException

handleGetSummary

private com.scivicslab.pojoactor.core.ActionResult handleGetSummary()
                                                             throws ExecutionException,
InterruptedException

Handles the getSummary action.

Returns:

ActionResult with the formatted summary

Throws:

ExecutionException

InterruptedException

handleGetCount

private com.scivicslab.pojoactor.core.ActionResult handleGetCount()
                                                           throws ExecutionException,
InterruptedException

Handles the getCount action.

Returns:

ActionResult with the count

Throws:

ExecutionException

InterruptedException

handleClear

private com.scivicslab.pojoactor.core.ActionResult handleClear()
                                                        throws ExecutionException,
InterruptedException

Handles the clear action.

Returns:

ActionResult indicating success

Throws:

ExecutionException

InterruptedException