org.apache.activemq.artemis.core.postoffice.impl

Class DuplicateIDCacheImpl

java.lang.Object

org.apache.activemq.artemis.core.postoffice.impl.DuplicateIDCacheImpl

All Implemented Interfaces:

DuplicateIDCache

public class DuplicateIDCacheImpl
extends Object
implements DuplicateIDCache

A DuplicateIDCacheImpl A fixed size rotating cache of last X duplicate ids.

Constructor Summary

Constructors

Constructor and Description
DuplicateIDCacheImpl(SimpleString address, int size, StorageManager storageManager, boolean persist)

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DuplicateIDCacheImpl

public DuplicateIDCacheImpl(SimpleString address,
                            int size,
                            StorageManager storageManager,
                            boolean persist)

Method Detail

load

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

Specified by:

load in interface DuplicateIDCache

Throws:

Exception

deleteFromCache

public void deleteFromCache(byte[] duplicateID)
                     throws Exception

Specified by:

deleteFromCache in interface DuplicateIDCache

Throws:

Exception

contains

public boolean contains(byte[] duplID)

Specified by:

contains in interface DuplicateIDCache

addToCache

public void addToCache(byte[] duplID)
                throws Exception

Specified by:

addToCache in interface DuplicateIDCache

Throws:

Exception

addToCache

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

Specified by:

addToCache in interface DuplicateIDCache

Throws:

Exception

atomicVerify

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

Specified by:

atomicVerify in interface DuplicateIDCache

Throws:

Exception

addToCache

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

Description copied from interface: DuplicateIDCache

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

Specified by:

addToCache in interface DuplicateIDCache

Throws:

Exception

load

public void load(Transaction tx,
                 byte[] duplID)

Specified by:

load in interface DuplicateIDCache

clear

public void clear()
           throws Exception

Specified by:

clear in interface DuplicateIDCache

Throws:

Exception

getMap

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

Specified by:

getMap in interface DuplicateIDCache