Package one.microstream.communication.binary.types

Class ComPersistenceChannelBinary.Default

java.lang.Object

one.microstream.communication.types.ComPersistenceChannel.Abstract<C,Binary>

one.microstream.communication.binary.types.ComPersistenceChannelBinary.Abstract<SocketChannel>

one.microstream.communication.binary.types.ComPersistenceChannelBinary.Default

All Implemented Interfaces:

WriteController, ComPersistenceChannelBinary<SocketChannel>, ComPersistenceChannel<SocketChannel,Binary>, PersistenceChannel<Binary>, PersistenceSource<Binary>, PersistenceTarget<Binary>, PersistenceWriteController

Enclosing interface:

ComPersistenceChannelBinary<C>

public static final class ComPersistenceChannelBinary.Default
extends ComPersistenceChannelBinary.Abstract<SocketChannel>

Nested Class Summary

Nested classes/interfaces inherited from interface one.microstream.communication.types.ComPersistenceChannel

ComPersistenceChannel.Abstract<C,D>

Nested classes/interfaces inherited from interface one.microstream.communication.binary.types.ComPersistenceChannelBinary

ComPersistenceChannelBinary.Abstract<C>, ComPersistenceChannelBinary.Default

Nested classes/interfaces inherited from interface one.microstream.persistence.types.PersistenceWriteController

PersistenceWriteController.Disabled, PersistenceWriteController.Enabled, PersistenceWriteController.Wrapper

Method Summary

Modifier and Type	Method	Description
void	closeSource()	Take actions to deactivate/close/destroy the source because it won't be read again.
void	closeTarget()	Take actions to deactivate/close/destroy the target because it won't be written to again.
protected XGettingCollection<? extends Binary>	internalRead(SocketChannel channel)
protected void	internalWrite(SocketChannel channel, Binary chunk)
boolean	isStoringEnabled()
boolean	isWritable()
void	prepareSource()	Prepare to read from this source.
void	prepareTarget()	Prepare to write to this target.
void	validateIsStoringEnabled()
void	validateIsWritable()

Methods inherited from class one.microstream.communication.binary.types.ComPersistenceChannelBinary.Abstract

ensureDefaultBuffer

Methods inherited from class one.microstream.communication.types.ComPersistenceChannel.Abstract

closeChannel, getConnection, prepareChannel, read, readByObjectIds, write

Methods inherited from class java.lang.Object

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

Methods inherited from interface one.microstream.persistence.types.PersistenceChannel

closeChannel, prepareChannel

Methods inherited from interface one.microstream.persistence.types.PersistenceSource

read, readByObjectIds

Methods inherited from interface one.microstream.persistence.types.PersistenceTarget

write

Method Details

internalRead

protected XGettingCollection<? extends Binary> internalRead(SocketChannel channel) throws PersistenceExceptionTransfer

Specified by:

internalRead in class ComPersistenceChannel.Abstract<SocketChannel,Binary>

Throws:

PersistenceExceptionTransfer

internalWrite

protected void internalWrite(SocketChannel channel, Binary chunk) throws PersistenceExceptionTransfer

Specified by:

internalWrite in class ComPersistenceChannel.Abstract<SocketChannel,Binary>

Throws:

PersistenceExceptionTransfer

prepareSource

public void prepareSource()

Description copied from interface: PersistenceSource

Prepare to read from this source. E.g. open a defined file.

Specified by:

prepareSource in interface PersistenceSource<Binary>

Specified by:

prepareSource in class ComPersistenceChannel.Abstract<SocketChannel,Binary>

prepareTarget

public void prepareTarget()

Description copied from interface: PersistenceTarget

Prepare to write to this target. E.g. open a defined file.

Specified by:

prepareTarget in interface PersistenceTarget<Binary>

Specified by:

prepareTarget in class ComPersistenceChannel.Abstract<SocketChannel,Binary>

closeSource

public void closeSource()

Description copied from interface: PersistenceSource

Take actions to deactivate/close/destroy the source because it won't be read again.

Specified by:

closeSource in interface PersistenceSource<Binary>

Specified by:

closeSource in class ComPersistenceChannel.Abstract<SocketChannel,Binary>

closeTarget

public void closeTarget()

Description copied from interface: PersistenceTarget

Take actions to deactivate/close/destroy the target because it won't be written to again.

Specified by:

closeTarget in interface PersistenceTarget<Binary>

Specified by:

closeTarget in class ComPersistenceChannel.Abstract<SocketChannel,Binary>

validateIsWritable

public final void validateIsWritable()

isWritable

public final boolean isWritable()

validateIsStoringEnabled

public void validateIsStoringEnabled()

isStoringEnabled

public boolean isStoringEnabled()