com.hazelcast.hibernate.serialization

Class Expirable

java.lang.Object

com.hazelcast.hibernate.serialization.Expirable

All Implemented Interfaces:

DataSerializable, IdentifiedDataSerializable

Direct Known Subclasses:

ExpiryMarker, Value

public abstract class Expirable
extends Object
implements IdentifiedDataSerializable

A container class which represents an entry in a region cache which can be marked for expiration

Field Summary

Fields

Modifier and Type	Field and Description
protected Object	version

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Expirable()
protected	Expirable(Object version)

Method Summary

Methods

Modifier and Type	Method and Description
abstract Object	getValue()
abstract Object	getValue(long txTimestamp)
Object	getVersion()
abstract boolean	isReplaceableBy(long txTimestamp, Object newVersion, Comparator versionComparator) Determine if the current entry can be overridden with a value corresponding to the given new version and the transaction timestamp.
abstract ExpiryMarker	markForExpiration(long timeout, String nextMarkerId) Mark the entry for expiration with the given timeout and marker id.
abstract boolean	matches(ExpiryMarker lock)
void	readData(ObjectDataInput in) Reads fields from the input stream
void	writeData(ObjectDataOutput out) Writes object fields to output stream

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.nio.serialization.IdentifiedDataSerializable

getFactoryId, getId

Field Detail

version

protected Object version

Constructor Detail

Expirable

protected Expirable()

Expirable

protected Expirable(Object version)

Method Detail

isReplaceableBy

public abstract boolean isReplaceableBy(long txTimestamp,
                      Object newVersion,
                      Comparator versionComparator)

Determine if the current entry can be overridden with a value corresponding to the given new version and the transaction timestamp.

Parameters:

txTimestamp - the timestamp of the transaction

newVersion - the new version for the replacement value

versionComparator - the comparator to use for the version

Returns:

true if the value can be replaced, false otherwise

getValue

public abstract Object getValue()

Returns:

the value contained, or null if none exists

getValue

public abstract Object getValue(long txTimestamp)

Parameters:

txTimestamp - the timestamp of the transaction

Returns:

the value contained if it was created before the transaction timestamp or null

getVersion

public Object getVersion()

Returns:

the version representing the value of null if the entry is not versioned

matches

public abstract boolean matches(ExpiryMarker lock)

Returns:

true if the Expirable matches using the specified lock, false otherwise

See Also:

ExpiryMarker.expire(long)

markForExpiration

public abstract ExpiryMarker markForExpiration(long timeout,
                             String nextMarkerId)

Mark the entry for expiration with the given timeout and marker id.

For every invocation a corresponding call to ExpiryMarker.expire(long) should be made, provided that the returned marker matches

Parameters:

timeout - the timestamp in which the lock times out

nextMarkerId - the next lock id to use if creating a new lock

Returns:

the newly created marker, or the current marker with a higher multiplicity

See Also:

ExpiryMarker.expire(long)

writeData

public void writeData(ObjectDataOutput out)
               throws IOException

Description copied from interface: DataSerializable

Writes object fields to output stream

Specified by:

writeData in interface DataSerializable

Parameters:

out - output

Throws:

IOException

readData

public void readData(ObjectDataInput in)
              throws IOException

Description copied from interface: DataSerializable

Reads fields from the input stream

Specified by:

readData in interface DataSerializable

Parameters:

in - input

Throws:

IOException