@ThreadSafe public class BatchingTransactionProcessor extends java.lang.Object implements TransactionProcessor
Constructor and Description |
---|
BatchingTransactionProcessor(DriverDiagnosticsImpl diagnosticsContext,
TransactionProcessor model,
java.util.concurrent.ScheduledExecutorService executor) |
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 . |
public BatchingTransactionProcessor(DriverDiagnosticsImpl diagnosticsContext, TransactionProcessor model, java.util.concurrent.ScheduledExecutorService executor)
public void processTransactions(java.util.List<BasicTransactionProcessor.SubscriptionTransaction> transactions)
processTransactions
in interface TransactionProcessor
transactions
- A SubscriptionTransaction to apply to the model.public void fireSubscriptionChanged()
TransactionProcessor
fireSubscriptionChanged
in interface TransactionProcessor
public int getItemCount()
getItemCount
in interface TransactionProcessor
SubscriptionItem
s.public void reset()
TransactionProcessor
TransactionProcessor
. All SubscriptionItem
s currently held will be discarded.reset
in interface TransactionProcessor