org.hornetq.core.postoffice.impl

Class DuplicateIDCacheImpl

java.lang.Object

org.hornetq.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.

Author:

Tim Fox Created 8 Dec 2008 16:35:55

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	addToCache(byte[] duplID, Transaction tx)
boolean	contains(byte[] duplID)
void	deleteFromCache(byte[] duplicateID)
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,
              Transaction tx)
                throws Exception

Specified by:

addToCache in interface DuplicateIDCache

Throws:

Exception

load

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

Specified by:

load in interface DuplicateIDCache