org.infinispan.client.hotrod.impl.protocol

Class AbstractVersionedInputStream

java.lang.Object

java.io.InputStream

org.infinispan.client.hotrod.impl.protocol.AbstractVersionedInputStream

All Implemented Interfaces:

Closeable, AutoCloseable, Metadata, Versioned, VersionedMetadata

Direct Known Subclasses:

ChannelInputStream

@NotThreadSafe
public abstract class AbstractVersionedInputStream
extends InputStream
implements VersionedMetadata

Field Summary

Fields

Modifier and Type	Field and Description
protected Runnable	afterClose
protected VersionedMetadata	versionedMetadata

Constructor Summary

Constructors

Constructor and Description
AbstractVersionedInputStream(VersionedMetadata versionedMetadata, Runnable afterClose)

Method Summary

Modifier and Type	Method and Description
void	close()
long	getCreated()
long	getLastUsed()
int	getLifespan()
int	getMaxIdle()
long	getVersion()

Methods inherited from class java.io.InputStream

available, mark, markSupported, read, read, read, reset, skip

Methods inherited from class java.lang.Object

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

Field Detail

versionedMetadata

protected final VersionedMetadata versionedMetadata

afterClose

protected final Runnable afterClose

Constructor Detail

AbstractVersionedInputStream

public AbstractVersionedInputStream(VersionedMetadata versionedMetadata,
                                    Runnable afterClose)

Method Detail

getVersion

public long getVersion()

Specified by:

getVersion in interface Versioned

getCreated

public long getCreated()

Specified by:

getCreated in interface Metadata

Returns:

Time when entry was created. -1 for immortal entries.

getLifespan

public int getLifespan()

Specified by:

getLifespan in interface Metadata

Returns:

Lifespan of the entry in seconds. Negative values are interpreted as unlimited lifespan.

getLastUsed

public long getLastUsed()

Specified by:

getLastUsed in interface Metadata

Returns:

Time when entry was last used. -1 for immortal entries.

getMaxIdle

public int getMaxIdle()

Specified by:

getMaxIdle in interface Metadata

Returns:

The maximum amount of time (in seconds) this key is allowed to be idle for before it is considered as expired.

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class InputStream

Throws:

IOException