Package org.apache.activemq.artemis.core.journal.collections

Class AbstractHashMapPersister<K,V>

java.lang.Object

org.apache.activemq.artemis.core.journal.collections.AbstractHashMapPersister<K,V>

All Implemented Interfaces:

Persister<JournalHashMap.MapRecord<K,V>>

Direct Known Subclasses:

AckRetry.Persister

public abstract class AbstractHashMapPersister<K,V>
extends Object
implements Persister<JournalHashMap.MapRecord<K,V>>

Constructor Summary

Constructors

Constructor	Description
AbstractHashMapPersister()

Method Summary

Modifier and Type	Method	Description
final JournalHashMap.MapRecord<K,V>	decode(ActiveMQBuffer buffer, JournalHashMap.MapRecord<K,V> record, CoreMessageObjectPools pool)
protected abstract K	decodeKey(ActiveMQBuffer buffer)
protected abstract V	decodeValue(ActiveMQBuffer buffer, K key)
final void	encode(ActiveMQBuffer buffer, JournalHashMap.MapRecord<K,V> record)
protected abstract void	encodeKey(ActiveMQBuffer buffer, K key)
protected abstract void	encodeValue(ActiveMQBuffer buffer, V value)
final int	getEncodeSize(JournalHashMap.MapRecord<K,V> record)
byte	getID()	This is to be used to store the protocol-id on Messages.
protected abstract int	getKeySize(K key)
protected abstract int	getValueSize(V value)

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractHashMapPersister

public AbstractHashMapPersister()

Method Details

getID

public byte getID()

Description copied from interface: Persister

This is to be used to store the protocol-id on Messages. Messages are stored on their bare format. The protocol manager will be responsible to code or decode messages. The caveat here is that the first short-sized bytes need to be this constant.

Specified by:

getID in interface Persister<K>

getEncodeSize

public final int getEncodeSize(JournalHashMap.MapRecord<K,V> record)

Specified by:

getEncodeSize in interface Persister<K>

getKeySize

protected abstract int getKeySize(K key)

encodeKey

protected abstract void encodeKey(ActiveMQBuffer buffer,
 K key)

decodeKey

protected abstract K decodeKey(ActiveMQBuffer buffer)

getValueSize

protected abstract int getValueSize(V value)

encodeValue

protected abstract void encodeValue(ActiveMQBuffer buffer,
 V value)

decodeValue

protected abstract V decodeValue(ActiveMQBuffer buffer,
 K key)

encode

public final void encode(ActiveMQBuffer buffer,
 JournalHashMap.MapRecord<K,V> record)

Specified by:

encode in interface Persister<K>

decode

public final JournalHashMap.MapRecord<K,V> decode(ActiveMQBuffer buffer,
 JournalHashMap.MapRecord<K,V> record,
 CoreMessageObjectPools pool)

Specified by:

decode in interface Persister<K>