TransactionProcessorImpl

java.lang.Object
- nxt.blockchain.TransactionProcessorImpl

All Implemented Interfaces:

TransactionProcessor, Observable<java.util.List<? extends Transaction>,TransactionProcessor.Event>
```
public final class TransactionProcessorImpl
extends java.lang.Object
implements TransactionProcessor
```

Nested Class Summary
- Nested classes/interfaces inherited from interface nxt.blockchain.TransactionProcessor
  TransactionProcessor.Event

Field Summary

Fields
Modifier and Type Field and Description

static int maxUnconfirmedTransactions

Fields
Modifier and Type	Field and Description
`static int`	`maxUnconfirmedTransactions`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`boolean`	`addListener(Listener<java.util.List<? extends Transaction>> listener, TransactionProcessor.Event eventType)`
`void`	`broadcast(Transaction transaction)`
`void`	`broadcastLater(Transaction transaction)`
`void`	`clearUnconfirmedTransactions()`
`java.util.List<ChainTransactionId>`	`filterPeerRequestIds(java.util.stream.Stream<ChainTransactionId> requestIdsStream, int maxSize)` Filter out any of the IDs that are known to be already available in the pool or forged.
`java.util.List<Transaction>`	`filterPeerTransactions(java.util.List<Transaction> transactions)`
`TransactionImpl[]`	`getAllBroadcastedTransactions()`
`java.util.List<java.lang.Long>`	`getAllUnconfirmedTransactionIds()`
`DbIterator<UnconfirmedTransaction>`	`getAllUnconfirmedTransactions()`
`DbIterator<UnconfirmedTransaction>`	`getAllUnconfirmedTransactions(int from, int to)`
`DbIterator<UnconfirmedTransaction>`	`getAllUnconfirmedTransactions(int from, int to, java.lang.String sort)`
`DbIterator<UnconfirmedTransaction>`	`getAllUnconfirmedTransactions(java.lang.String sort)`
`UnconfirmedTransaction[]`	`getAllWaitingTransactions()`
`java.util.SortedSet<? extends Transaction>`	`getCachedUnconfirmedTransactions(java.util.List<java.lang.Long> exclude)` Get the cached unconfirmed transactions
`static TransactionProcessorImpl`	`getInstance()`
`DbIterator<UnconfirmedTransaction>`	`getUnconfirmedChildTransactions(ChildChain childChain)`
`DbIterator<UnconfirmedTransaction>`	`getUnconfirmedFxtTransactions()`
`java.util.Map<java.lang.String,java.lang.Object>`	`getUnconfirmedPoolInfo()`
`int`	`getUnconfirmedPoolSize()`
`UnconfirmedTransaction`	`getUnconfirmedTransaction(long transactionId)`
`java.util.Collection<UnconfirmedTransaction>`	`getWaitingTransactions()`
`static void`	`init()`
`void`	`notifyListeners(java.util.List<? extends Transaction> transactions, TransactionProcessor.Event eventType)`
`void`	`processLater(java.util.Collection<? extends FxtTransaction> transactions)`
`java.util.List<TransactionImpl>`	`processPeerTransactions(java.util.List<Transaction> transactions)`
`void`	`rebroadcastAllUnconfirmedTransactions()`
`boolean`	`removeListener(Listener<java.util.List<? extends Transaction>> listener, TransactionProcessor.Event eventType)`
`void`	`requeueAllUnconfirmedTransactions()`
`java.util.List<Transaction>`	`restorePrunableData(java.util.List<Transaction> transactions)` Restore expired prunable data

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - maxUnconfirmedTransactions
```
public static final int maxUnconfirmedTransactions
```
- Method Detail
  - getInstance
```
public static TransactionProcessorImpl getInstance()
```
  - init
```
public static void init()
```
  - addListener
```
public boolean addListener(Listener<java.util.List<? extends Transaction>> listener,
                           TransactionProcessor.Event eventType)
```
    Specified by:
    
    addListener in interface Observable<java.util.List<? extends Transaction>,TransactionProcessor.Event>
  - removeListener
```
public boolean removeListener(Listener<java.util.List<? extends Transaction>> listener,
                              TransactionProcessor.Event eventType)
```
    Specified by:
    
    removeListener in interface Observable<java.util.List<? extends Transaction>,TransactionProcessor.Event>
  - notifyListeners
```
public void notifyListeners(java.util.List<? extends Transaction> transactions,
                            TransactionProcessor.Event eventType)
```
  - getAllUnconfirmedTransactions
```
public DbIterator<UnconfirmedTransaction> getAllUnconfirmedTransactions()
```
    Specified by:
    
    getAllUnconfirmedTransactions in interface TransactionProcessor
  - getAllUnconfirmedTransactions
```
public DbIterator<UnconfirmedTransaction> getAllUnconfirmedTransactions(int from,
                                                                        int to)
```
    Specified by:
    
    getAllUnconfirmedTransactions in interface TransactionProcessor
  - getAllUnconfirmedTransactions
```
public DbIterator<UnconfirmedTransaction> getAllUnconfirmedTransactions(java.lang.String sort)
```
    Specified by:
    
    getAllUnconfirmedTransactions in interface TransactionProcessor
  - getAllUnconfirmedTransactions
```
public DbIterator<UnconfirmedTransaction> getAllUnconfirmedTransactions(int from,
                                                                        int to,
                                                                        java.lang.String sort)
```
    Specified by:
    
    getAllUnconfirmedTransactions in interface TransactionProcessor
  - getUnconfirmedFxtTransactions
```
public DbIterator<UnconfirmedTransaction> getUnconfirmedFxtTransactions()
```
    Specified by:
    
    getUnconfirmedFxtTransactions in interface TransactionProcessor
  - getUnconfirmedChildTransactions
```
public DbIterator<UnconfirmedTransaction> getUnconfirmedChildTransactions(ChildChain childChain)
```
    Specified by:
    
    getUnconfirmedChildTransactions in interface TransactionProcessor
  - getUnconfirmedTransaction
```
public UnconfirmedTransaction getUnconfirmedTransaction(long transactionId)
```
    Specified by:
    
    getUnconfirmedTransaction in interface TransactionProcessor
  - getAllUnconfirmedTransactionIds
```
public java.util.List<java.lang.Long> getAllUnconfirmedTransactionIds()
```
    Specified by:
    
    getAllUnconfirmedTransactionIds in interface TransactionProcessor
  - getUnconfirmedPoolSize
```
public int getUnconfirmedPoolSize()
```
  - getAllWaitingTransactions
```
public UnconfirmedTransaction[] getAllWaitingTransactions()
```
    Specified by:
    
    getAllWaitingTransactions in interface TransactionProcessor
  - getWaitingTransactions
```
public java.util.Collection<UnconfirmedTransaction> getWaitingTransactions()
```
  - getAllBroadcastedTransactions
```
public TransactionImpl[] getAllBroadcastedTransactions()
```
    Specified by:
    
    getAllBroadcastedTransactions in interface TransactionProcessor
  - broadcast
```
public void broadcast(Transaction transaction)
               throws NxtException.ValidationException
```
    Specified by:
    
    broadcast in interface TransactionProcessor
    
    Throws:
    
    NxtException.ValidationException
  - broadcastLater
```
public void broadcastLater(Transaction transaction)
```
    Specified by:
    
    broadcastLater in interface TransactionProcessor
  - clearUnconfirmedTransactions
```
public void clearUnconfirmedTransactions()
```
    Specified by:
    
    clearUnconfirmedTransactions in interface TransactionProcessor
  - requeueAllUnconfirmedTransactions
```
public void requeueAllUnconfirmedTransactions()
```
    Specified by:
    
    requeueAllUnconfirmedTransactions in interface TransactionProcessor
  - rebroadcastAllUnconfirmedTransactions
```
public void rebroadcastAllUnconfirmedTransactions()
```
    Specified by:
    
    rebroadcastAllUnconfirmedTransactions in interface TransactionProcessor
  - processLater
```
public void processLater(java.util.Collection<? extends FxtTransaction> transactions)
```
    Specified by:
    
    processLater in interface TransactionProcessor
  - filterPeerRequestIds
```
public java.util.List<ChainTransactionId> filterPeerRequestIds(java.util.stream.Stream<ChainTransactionId> requestIdsStream,
                                                               int maxSize)
```
    Filter out any of the IDs that are known to be already available in the pool or forged. And filter out any ids that are known to be dropped unless they are with better priority than some of the transactions in the pool or the pool is not full
    
    Specified by:
    
    filterPeerRequestIds in interface TransactionProcessor
    
    Parameters:
    
    requestIdsStream - stream of ids
    
    maxSize - maxSize
    
    Returns:
    
    A list of filtered
  - filterPeerTransactions
```
public java.util.List<Transaction> filterPeerTransactions(java.util.List<Transaction> transactions)
```
    Specified by:
    
    filterPeerTransactions in interface TransactionProcessor
  - processPeerTransactions
```
public java.util.List<TransactionImpl> processPeerTransactions(java.util.List<Transaction> transactions)
                                                        throws NxtException.NotValidException
```
    Specified by:
    
    processPeerTransactions in interface TransactionProcessor
    
    Throws:
    
    NxtException.NotValidException
  - getCachedUnconfirmedTransactions
```
public java.util.SortedSet<? extends Transaction> getCachedUnconfirmedTransactions(java.util.List<java.lang.Long> exclude)
```
    Get the cached unconfirmed transactions
    
    Specified by:
    
    getCachedUnconfirmedTransactions in interface TransactionProcessor
    
    Parameters:
    
    exclude - List of transaction identifiers to exclude
  - restorePrunableData
```
public java.util.List<Transaction> restorePrunableData(java.util.List<Transaction> transactions)
```
    Restore expired prunable data
    
    Specified by:
    
    restorePrunableData in interface TransactionProcessor
    
    Parameters:
    
    transactions - Transactions containing prunable data
    
    Returns:
    
    Processed transactions
  - getUnconfirmedPoolInfo
```
public java.util.Map<java.lang.String,java.lang.Object> getUnconfirmedPoolInfo()
```
    Specified by:
    
    getUnconfirmedPoolInfo in interface TransactionProcessor

Class TransactionProcessorImpl

Nested Class Summary

Nested classes/interfaces inherited from interface nxt.blockchain.TransactionProcessor

Field Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

maxUnconfirmedTransactions

Method Detail

getInstance

init

addListener

removeListener

notifyListeners

getAllUnconfirmedTransactions

getAllUnconfirmedTransactions

getAllUnconfirmedTransactions

getAllUnconfirmedTransactions

getUnconfirmedFxtTransactions

getUnconfirmedChildTransactions

getUnconfirmedTransaction

getAllUnconfirmedTransactionIds

getUnconfirmedPoolSize

getAllWaitingTransactions

getWaitingTransactions

getAllBroadcastedTransactions

broadcast

broadcastLater

clearUnconfirmedTransactions

requeueAllUnconfirmedTransactions

rebroadcastAllUnconfirmedTransactions

processLater

filterPeerRequestIds

filterPeerTransactions

processPeerTransactions

getCachedUnconfirmedTransactions

restorePrunableData

getUnconfirmedPoolInfo