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

Class NoOpDuplicateIDCache

java.lang.Object

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

All Implemented Interfaces:

DuplicateIDCache

public final class NoOpDuplicateIDCache
extends Object
implements DuplicateIDCache

Constructor Summary

Constructors

Constructor	Description
NoOpDuplicateIDCache()

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)

Methods inherited from class java.lang.Object

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

Constructor Details

NoOpDuplicateIDCache

public NoOpDuplicateIDCache()

Method Details

contains

public boolean contains(byte[] duplicateID)

Specified by:

contains in interface DuplicateIDCache

atomicVerify

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

Specified by:

atomicVerify in interface DuplicateIDCache

Throws:

Exception

addToCache

public void addToCache(byte[] duplicateID)
                throws Exception

Specified by:

addToCache in interface DuplicateIDCache

Throws:

Exception

addToCache

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

Specified by:

addToCache in interface DuplicateIDCache

Throws:

Exception

addToCache

public void addToCache(byte[] duplicateID,
 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

deleteFromCache

public void deleteFromCache(byte[] duplicateID)
                     throws Exception

Specified by:

deleteFromCache in interface DuplicateIDCache

Throws:

Exception

load

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

Specified by:

load 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

getSize

public int getSize()

Specified by:

getSize in interface DuplicateIDCache