com.inductiveautomation.xopc.driver.api

Class BatchingTransactionProcessor

java.lang.Object

com.inductiveautomation.xopc.driver.api.BatchingTransactionProcessor

All Implemented Interfaces:

TransactionProcessor

@ThreadSafe
public class BatchingTransactionProcessor
extends java.lang.Object
implements TransactionProcessor

Constructor Summary

Constructors

Constructor and Description
BatchingTransactionProcessor(DriverDiagnosticsImpl diagnosticsContext, TransactionProcessor model, java.util.concurrent.ScheduledExecutorService executor)

Method Summary

Modifier and Type	Method and Description
void	fireSubscriptionChanged() Force the TransactionProcessor to fire a subscriptionChange() call to its SubscriptionChangeCallback.
int	getItemCount()
void	processTransactions(java.util.List<BasicTransactionProcessor.SubscriptionTransaction> transactions)
void	reset() Reset this TransactionProcessor.

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchingTransactionProcessor

public BatchingTransactionProcessor(DriverDiagnosticsImpl diagnosticsContext,
                                    TransactionProcessor model,
                                    java.util.concurrent.ScheduledExecutorService executor)

Method Detail

processTransactions

public void processTransactions(java.util.List<BasicTransactionProcessor.SubscriptionTransaction> transactions)

Specified by:

processTransactions in interface TransactionProcessor

Parameters:

transactions - A SubscriptionTransaction to apply to the model.

fireSubscriptionChanged

public void fireSubscriptionChanged()

Description copied from interface: TransactionProcessor

Force the TransactionProcessor to fire a subscriptionChange() call to its SubscriptionChangeCallback.

Specified by:

fireSubscriptionChanged in interface TransactionProcessor

getItemCount

public int getItemCount()

Specified by:

getItemCount in interface TransactionProcessor

Returns:

The count of SubscriptionItems.

reset

public void reset()

Description copied from interface: TransactionProcessor

Reset this TransactionProcessor. All SubscriptionItems currently held will be discarded.

Specified by:

reset in interface TransactionProcessor