Package one.microstream.storage.types

Class StorageOperationController.Default

java.lang.Object

one.microstream.storage.types.StorageOperationController.Default

All Implemented Interfaces:

StorageOperationController

Enclosing interface:

StorageOperationController

public static final class StorageOperationController.Default
extends Object
implements StorageOperationController

Nested Class Summary

Nested classes/interfaces inherited from interface one.microstream.storage.types.StorageOperationController

StorageOperationController.Creator, StorageOperationController.Default

Constructor Summary

Constructors

Constructor	Description
Default()

Method Summary

Modifier and Type	Method	Description
void	activate()
StorageChannelCountProvider	channelCountProvider()
boolean	checkProcessingEnabled()
void	deactivate()
XGettingSequence<Throwable>	disruptingProblems()
boolean	hasDisruptingProblems()
boolean	isChannelProcessingEnabled()
void	registerDisruptingProblem(Throwable problem)
void	setChannelProcessingEnabled(boolean enabled)

Methods inherited from class java.lang.Object

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

Constructor Detail

Default

public Default()

Method Detail

setChannelProcessingEnabled

public final void setChannelProcessingEnabled(boolean enabled)

Specified by:

setChannelProcessingEnabled in interface StorageOperationController

isChannelProcessingEnabled

public final boolean isChannelProcessingEnabled()

Specified by:

isChannelProcessingEnabled in interface StorageOperationController

channelCountProvider

public final StorageChannelCountProvider channelCountProvider()

Specified by:

channelCountProvider in interface StorageOperationController

activate

public final void activate()

Specified by:

activate in interface StorageOperationController

deactivate

public final void deactivate()

Specified by:

deactivate in interface StorageOperationController

checkProcessingEnabled

public final boolean checkProcessingEnabled()
                                     throws StorageExceptionDisruptingExceptions

Specified by:

checkProcessingEnabled in interface StorageOperationController

Throws:

StorageExceptionDisruptingExceptions

registerDisruptingProblem

public final void registerDisruptingProblem(Throwable problem)

Specified by:

registerDisruptingProblem in interface StorageOperationController

disruptingProblems

public final XGettingSequence<Throwable> disruptingProblems()

Specified by:

disruptingProblems in interface StorageOperationController

hasDisruptingProblems

public final boolean hasDisruptingProblems()

Specified by:

hasDisruptingProblems in interface StorageOperationController