org.rvpf.store.server

Class Notifier.Abstract

Object

Notifier.Abstract

All Implemented Interfaces:

NoticeListener, Notifier

Direct Known Subclasses:

NullNotifier, SOMNotifier

Enclosing interface:

Notifier

public abstract static class Notifier.Abstract
extends Object
implements Notifier

Abstract notifier.

Nested Class Summary

Nested classes/interfaces inherited from interface Notifier

Notifier.Abstract

Field Summary

Fields

Modifier and Type	Field and Description
static String	NOTIFIED_TRACES Traces subdirectory for notified values.

Constructor Summary

Constructors

Constructor and Description
Abstract()

Method Summary

Modifier and Type	Method and Description
protected void	addTime(long time) Adds time.
void	close() Closes this notifier.
void	commit() Commits the pending notices.
protected abstract boolean	doNotify(PointValue pointValue) Does notify of a new Point value.
protected int	getNoticeCount() Gets the notices count.
protected StoreServiceAppImpl	getStoreAppImpl() Gets the store application implementation.
protected Logger	getThisLogger() Gets the logger.
protected boolean	isClosed() Asks if this notifier is closed.
boolean	join() Joins whatever thread set up by this notifier.
void	notify(PointValue pointValue) Notifies of a new Point value.
void	setFilter(Optional<Collection<Point>> noticesFilter) Sets the filter.
boolean	setUp(StoreServiceAppImpl storeAppImpl) Sets up for processing.
void	start() Starts this.
void	tearDown() Tears down what has been set up.

Methods inherited from class Object

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

Field Detail

NOTIFIED_TRACES

public static final String NOTIFIED_TRACES

Traces subdirectory for notified values.

See Also:

Constant Field Values

Constructor Detail

Abstract

public Abstract()

Method Detail

close

public void close()

Closes this notifier.

Specified by:

close in interface Notifier

commit

public void commit()
            throws InterruptedException

Commits the pending notices.

Specified by:

commit in interface NoticeListener

Throws:

InterruptedException - When the Service is stopped.

join

public boolean join()

Joins whatever thread set up by this notifier.

Specified by:

join in interface Notifier

Returns:

True on success.

notify

public final void notify(PointValue pointValue)
                  throws InterruptedException

Notifies of a new Point value.

Specified by:

notify in interface NoticeListener

Parameters:

pointValue - The Point value.

Throws:

InterruptedException - When the Service is stopped.

setFilter

public final void setFilter(Optional<Collection<Point>> noticesFilter)

Sets the filter.

Specified by:

setFilter in interface Notifier

Parameters:

noticesFilter - A Collection of points for which to generate notices.

setUp

public boolean setUp(StoreServiceAppImpl storeAppImpl)

Sets up for processing.

Specified by:

setUp in interface Notifier

Parameters:

storeAppImpl - The store application implementation.

Returns:

True if successful.

start

public void start()

Starts this.

Specified by:

start in interface Notifier

tearDown

public void tearDown()

Tears down what has been set up.

Specified by:

tearDown in interface Notifier

addTime

protected final void addTime(long time)

Adds time.

Parameters:

time - The time increment in nanoseconds.

doNotify

@CheckReturnValue
protected abstract boolean doNotify(@Nonnull
                                                       PointValue pointValue)
                                                throws InterruptedException

Does notify of a new Point value.

Parameters:

pointValue - The Point value.

Returns:

True on success.

Throws:

InterruptedException - When the Service is stopped.

getNoticeCount

@CheckReturnValue
protected final int getNoticeCount()

Gets the notices count.

Returns:

The notices count.

getStoreAppImpl

@Nonnull
 @CheckReturnValue
protected final StoreServiceAppImpl getStoreAppImpl()

Gets the store application implementation.

Returns:

The store application implementation.

getThisLogger

@Nonnull
 @CheckReturnValue
protected final Logger getThisLogger()

Gets the logger.

Returns:

The logger.

isClosed

@CheckReturnValue
protected boolean isClosed()

Asks if this notifier is closed.

Returns:

True if this notifier is closed.