org.oddjob.events

Class StreamWatcher

java.lang.Object

org.oddjob.framework.extend.BaseComponent

org.oddjob.framework.extend.BasePrimary

org.oddjob.events.EventSourceBase<java.lang.String>

org.oddjob.events.StreamWatcher

All Implemented Interfaces:

ArooaContextAware, ArooaSessionAware, EventSource<java.lang.String>, PropertyChangeNotifier, Iconic, LogEnabled, Resetable, Stateful

public class StreamWatcher
extends EventSourceBase<java.lang.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 typeical 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 and Description
StreamWatcher()

Method Summary

Modifier and Type	Method and Description
protected Restore	doStart(java.util.function.Consumer<? super EventOf<java.lang.String>> consumer)
java.io.OutputStream	getOut()
java.lang.String	getWatch()
void	setWatch(java.lang.String watch)

Methods inherited from class org.oddjob.events.EventSourceBase

fireDestroyedState, getStateChanger, hardReset, iconHelper, onHardReset, onReset, onSoftReset, setStateException, softReset, start, stateHandler

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

Constructor Detail

StreamWatcher

public StreamWatcher()

Method Detail

doStart

protected Restore doStart(java.util.function.Consumer<? super EventOf<java.lang.String>> consumer)
                   throws java.lang.Exception

Specified by:

doStart in class EventSourceBase<java.lang.String>

Throws:

java.lang.Exception

getWatch

public java.lang.String getWatch()

setWatch

public void setWatch(java.lang.String watch)

getOut

public java.io.OutputStream getOut()