Package nxt.blockchain

Interface TransactionProcessor

All Superinterfaces:

Observable<List<? extends Transaction>,TransactionProcessor.Event>

All Known Implementing Classes:

TransactionProcessorImpl

public interface TransactionProcessor
extends Observable<List<? extends Transaction>,TransactionProcessor.Event>

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	TransactionProcessor.Event

Method Summary

Modifier and Type	Method	Description
void	broadcast(Transaction transaction)
void	broadcastLater(Transaction transaction)
void	clearUnconfirmedTransactions()
List<ChainTransactionId>	filterPeerRequestIds(Stream<ChainTransactionId> requestIdsStream, int maxSize)
List<Transaction>	filterPeerTransactions(List<Transaction> transactions)
Transaction[]	getAllBroadcastedTransactions()
List<Long>	getAllUnconfirmedTransactionIds()
DbIterator<? extends Transaction>	getAllUnconfirmedTransactions()
DbIterator<? extends Transaction>	getAllUnconfirmedTransactions(int from, int to)
DbIterator<? extends Transaction>	getAllUnconfirmedTransactions(int from, int to, String sort)
DbIterator<? extends Transaction>	getAllUnconfirmedTransactions(String sort)
UnconfirmedTransaction[]	getAllWaitingTransactions()
List<? extends Transaction>	getCachedUnconfirmedTransactions(List<Long> exclude, int maxCount)
DbIterator<? extends Transaction>	getUnconfirmedChildTransactions(ChildChain chain)
DbIterator<? extends Transaction>	getUnconfirmedFxtTransactions()
Map<String,Object>	getUnconfirmedPoolInfo()
UnconfirmedTransaction	getUnconfirmedTransaction(long transactionId)
void	processLater(Collection<? extends FxtTransaction> transactions)
List<? extends Transaction>	processPeerTransactions(List<Transaction> transactions)
void	rebroadcastAllUnconfirmedTransactions()
void	requeueAllUnconfirmedTransactions()
List<Transaction>	restorePrunableData(List<Transaction> transactions)

Methods inherited from interface nxt.util.Observable

addListener, removeListener

Method Details

getAllUnconfirmedTransactionIds

List<Long> getAllUnconfirmedTransactionIds()

getAllUnconfirmedTransactions

DbIterator<? extends Transaction> getAllUnconfirmedTransactions()

getAllUnconfirmedTransactions

DbIterator<? extends Transaction> getAllUnconfirmedTransactions(int from,
 int to)

getAllUnconfirmedTransactions

DbIterator<? extends Transaction> getAllUnconfirmedTransactions(String sort)

getAllUnconfirmedTransactions

DbIterator<? extends Transaction> getAllUnconfirmedTransactions(int from,
 int to,
 String sort)

getUnconfirmedFxtTransactions

DbIterator<? extends Transaction> getUnconfirmedFxtTransactions()

getUnconfirmedChildTransactions

DbIterator<? extends Transaction> getUnconfirmedChildTransactions(ChildChain chain)

getUnconfirmedTransaction

UnconfirmedTransaction getUnconfirmedTransaction(long transactionId)

getAllWaitingTransactions

UnconfirmedTransaction[] getAllWaitingTransactions()

getAllBroadcastedTransactions

Transaction[] getAllBroadcastedTransactions()

clearUnconfirmedTransactions

void clearUnconfirmedTransactions()

requeueAllUnconfirmedTransactions

void requeueAllUnconfirmedTransactions()

rebroadcastAllUnconfirmedTransactions

void rebroadcastAllUnconfirmedTransactions()

broadcast

void broadcast(Transaction transaction)
        throws NxtException.ValidationException

Throws:

NxtException.ValidationException

broadcastLater

void broadcastLater(Transaction transaction)

filterPeerRequestIds

List<ChainTransactionId> filterPeerRequestIds(Stream<ChainTransactionId> requestIdsStream,
 int maxSize)

filterPeerTransactions

List<Transaction> filterPeerTransactions(List<Transaction> transactions)

processPeerTransactions

List<? extends Transaction> processPeerTransactions(List<Transaction> transactions)
                                             throws NxtException.NotValidException

Throws:

NxtException.NotValidException

processLater

void processLater(Collection<? extends FxtTransaction> transactions)

getCachedUnconfirmedTransactions

List<? extends Transaction> getCachedUnconfirmedTransactions(List<Long> exclude,
 int maxCount)

restorePrunableData

List<Transaction> restorePrunableData(List<Transaction> transactions)

getUnconfirmedPoolInfo

Map<String,Object> getUnconfirmedPoolInfo()