Class PollingAutomationPerTableRunner

java.lang.Object

com.kingsrook.qqq.backend.core.actions.automation.polling.PollingAutomationPerTableRunner

All Implemented Interfaces:

Runnable

public class PollingAutomationPerTableRunner
extends Object
implements Runnable

Runnable for the Polling Automation Provider, that looks for records that need automations, and executes them. An instance of this class should be created for each table/automation-status - see the TableActions inner record for that definition, and the static getTableActions method that helps someone who wants to start these threads figure out which ones are needed.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	PollingAutomationPerTableRunner.ShardedTableActions	extended version of TableAction, for sharding use-case - adds the shard details.
static final record	PollingAutomationPerTableRunner.TableActions	Wrapper for a pair of (tableName, automationStatus)
static interface	PollingAutomationPerTableRunner.TableActionsInterface	Interface to be used by 2 records in this class - normal TableActions, and ShardedTableActions.

Constructor Summary

Constructors

Constructor	Description
PollingAutomationPerTableRunner(QInstance instance, String providerName, Supplier<QSession> sessionSupplier, PollingAutomationPerTableRunner.TableActionsInterface tableActions)

Method Summary

Modifier and Type	Method	Description
static void	applyActionToMatchingRecords(QTableMetaData table, List<QRecord> records, TableAutomationAction action)	Finally, actually run action code against a list of known matching records.
protected boolean	applyActionToRecords(QTableMetaData table, List<QRecord> records, TableAutomationAction action)	Run one action over a list of records (if they match the action's filter).
String	getName()	Getter for name
static List<PollingAutomationPerTableRunner.TableActionsInterface>	getTableActions(QInstance instance, String providerName)	basically just get a list of tables which at least *could* have automations run - either meta-data automations, or table-triggers (data/user defined).
void	processTableInsertOrUpdate(QTableMetaData table, AutomationStatus automationStatus)	Query for and process records that have a PENDING_INSERT or PENDING_UPDATE status on a given table.
void	run()

Methods inherited from class java.lang.Object

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

Constructor Details

PollingAutomationPerTableRunner

public PollingAutomationPerTableRunner(QInstance instance,
 String providerName,
 Supplier<QSession> sessionSupplier,
 PollingAutomationPerTableRunner.TableActionsInterface tableActions)

Method Details

getTableActions

public static List<PollingAutomationPerTableRunner.TableActionsInterface> getTableActions(QInstance instance,
 String providerName)

basically just get a list of tables which at least *could* have automations run - either meta-data automations, or table-triggers (data/user defined).

run

public void run()

Specified by:

run in interface Runnable

processTableInsertOrUpdate

public void processTableInsertOrUpdate(QTableMetaData table,
 AutomationStatus automationStatus)
                                throws QException

Query for and process records that have a PENDING_INSERT or PENDING_UPDATE status on a given table.

Throws:

QException

applyActionToRecords

protected boolean applyActionToRecords(QTableMetaData table,
 List<QRecord> records,
 TableAutomationAction action)

Run one action over a list of records (if they match the action's filter).

Returns:

hadError - true if an exception was caught; false if all OK.

applyActionToMatchingRecords

public static void applyActionToMatchingRecords(QTableMetaData table,
 List<QRecord> records,
 TableAutomationAction action)
                                         throws Exception

Finally, actually run action code against a list of known matching records.

Throws:

Exception

getName

public String getName()

Getter for name