@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()
TransactionProcessorfireSubscriptionChanged in interface TransactionProcessorpublic void processTransactions(java.util.List<BasicTransactionProcessor.SubscriptionTransaction> transactions)
processTransactions in interface TransactionProcessortransactions - A SubscriptionTransaction to apply to the model.public int getItemCount()
getItemCount in interface TransactionProcessorSubscriptionItems.public void reset()
TransactionProcessorTransactionProcessor. All SubscriptionItems currently held will be discarded.reset in interface TransactionProcessor