Package org.oddjob.events

Class StreamWatcher

java.lang.Object

org.oddjob.framework.extend.BaseComponent

org.oddjob.framework.extend.BasePrimary

org.oddjob.events.EventServiceBase<InstantEvent<String>>

org.oddjob.events.StreamWatcher

All Implemented Interfaces:

Runnable, ArooaContextAware, ArooaSessionAware, Outbound<InstantEvent<String>>, PropertyChangeNotifier, Iconic, LogEnabled, Resettable, Stateful, Stoppable

public class StreamWatcher
extends EventServiceBase<InstantEvent<String>>

Description

Watch a stream for an instance of a string. Typically this watcher (and its trigger) will be started before a job that produces some output that needs to be monitored.

A typical use case would be running an exec job that tails a log file, and this watcher is looking for the word "Error" or some such.

Constructor Summary

Constructors

Constructor	Description
StreamWatcher()

Method Summary

Modifier and Type	Method	Description
protected Restore	doStart(Consumer<? super InstantEvent<String>> consumer)
OutputStream	getOut()
String	getWatch()
void	setWatch(String watch)

Methods inherited from class org.oddjob.events.EventServiceBase

fireDestroyedState, getStateChanger, hardReset, iconHelper, onHardReset, onReset, onSoftReset, run, setStateException, setTo, softReset, stateHandler, stop

Methods inherited from class org.oddjob.framework.extend.BasePrimary

configure, getName, logger, logger, loggerName, save, setName, toString

Methods inherited from class org.oddjob.framework.extend.BaseComponent

addIconListener, addPropertyChangeListener, addStateListener, configure, destroy, firePropertyChange, getArooaSession, iconForId, initialise, lastStateEvent, onConfigured, onDestroy, onInitialised, removeIconListener, removePropertyChangeListener, removeStateListener, save, setArooaContext, setArooaSession

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.oddjob.Stateful

addStateListener, lastStateEvent, removeStateListener

Constructor Details

StreamWatcher

public StreamWatcher()

Method Details

doStart

protected Restore doStart(Consumer<? super InstantEvent<String>> consumer)

Specified by:

doStart in class EventServiceBase<InstantEvent<String>>

getWatch

public String getWatch()

setWatch

public void setWatch(String watch)

getOut

public OutputStream getOut()