Package org.apache.activemq.artemis.core.postoffice

Interface DuplicateIDCache

All Known Implementing Classes:

NoOpDuplicateIDCache

public interface DuplicateIDCache

Method Summary

Modifier and Type	Method	Description
void	addToCache(byte[] duplicateID)
void	addToCache(byte[] duplicateID, Transaction tx)
void	addToCache(byte[] duplicateID, Transaction tx, boolean instantAdd)	It will add the data to the cache.
boolean	atomicVerify(byte[] duplID, Transaction tx)
void	clear()
boolean	contains(byte[] duplicateID)
void	deleteFromCache(byte[] duplicateID)
List<Pair<byte[],Long>>	getMap()
int	getSize()
void	load(List<Pair<byte[],Long>> ids)
void	load(Transaction tx, byte[] duplID)

Method Details

contains

boolean contains(byte[] duplicateID)

atomicVerify

boolean atomicVerify(byte[] duplID,
 Transaction tx)
              throws Exception

Throws:

Exception

addToCache

void addToCache(byte[] duplicateID)
         throws Exception

Throws:

Exception

addToCache

void addToCache(byte[] duplicateID,
 Transaction tx)
         throws Exception

Throws:

Exception

getSize

int getSize()

addToCache

void addToCache(byte[] duplicateID,
 Transaction tx,
 boolean instantAdd)
         throws Exception

It will add the data to the cache. If TX == null it won't use a transaction. if instantAdd=true, it won't wait a transaction to add on the cache which is needed on the case of the Bridges

Throws:

Exception

deleteFromCache

void deleteFromCache(byte[] duplicateID)
              throws Exception

Throws:

Exception

load

void load(List<Pair<byte[],Long>> ids)
   throws Exception

Throws:

Exception

load

void load(Transaction tx,
 byte[] duplID)

clear

void clear()
    throws Exception

Throws:

Exception

getMap

List<Pair<byte[],Long>> getMap()