@NotThreadSafe public class BasicTransactionProcessor extends java.lang.Object implements TransactionProcessor
Modifier and Type | Class and Description |
---|---|
static interface |
BasicTransactionProcessor.SubscriptionChangeCallback |
static class |
BasicTransactionProcessor.SubscriptionTransaction |
Constructor and Description |
---|
BasicTransactionProcessor(DriverContext driverContext,
BasicTransactionProcessor.SubscriptionChangeCallback callback,
LoggerEx log) |
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 BasicTransactionProcessor(DriverContext driverContext, BasicTransactionProcessor.SubscriptionChangeCallback callback, LoggerEx log)
public void fireSubscriptionChanged()
TransactionProcessor
fireSubscriptionChanged
in interface TransactionProcessor
public void processTransactions(java.util.List<BasicTransactionProcessor.SubscriptionTransaction> transactions)
processTransactions
in interface TransactionProcessor
transactions
- A SubscriptionTransaction to apply to the model.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