public interface LogWatch extends MessageProducer<LogWatch>
Modifier and Type | Method and Description |
---|---|
File |
getWatchedFile()
The file that is being tracked by this class.
|
boolean |
isFollowedBy(Follower follower)
Whether or not
stopFollowing(Follower) has been called for a
given follower. |
boolean |
isHandingDown(MessageMeasure<? extends Number,Follower> measure)
Whether or not particular
MessageMeasure is being automatically
handed down to new Follower s. |
boolean |
isHandingDown(String id)
Whether or not particular
MessageMeasure is being automatically
handed down to new Follower s. |
boolean |
isStarted()
Whether or not
start() has been called. |
boolean |
isStopped()
Whether or not
stop() has been called. |
boolean |
start()
Start tailing the log file.
|
Follower |
startFollowing()
Begin watching for new messages from this point in time.
|
boolean |
startHandingDown(MessageMeasure<? extends Number,Follower> measure,
String id)
Every new
Follower from now on will immediately receive a new
MessageMetric instance with a given ID that is using the given
measure instance. |
boolean |
stop()
Stop all followers from following and free resources.
|
boolean |
stopFollowing(Follower follower)
Stop particular follower from following.
|
boolean |
stopHandingDown(MessageMeasure<? extends Number,Follower> measure)
Invalidate
startHandingDown(MessageMeasure, String) . |
boolean |
stopHandingDown(String id)
Invalidate
startHandingDown(MessageMeasure, String) . |
countConsumers, countMetrics, getMetric, getMetricId, isConsuming, isMeasuring, isMeasuring, startConsuming, startMeasuring, stopConsuming, stopMeasuring, stopMeasuring
File getWatchedFile()
boolean isFollowedBy(Follower follower)
stopFollowing(Follower)
has been called for a
given follower.follower
- Tailer in question.boolean isHandingDown(MessageMeasure<? extends Number,Follower> measure)
MessageMeasure
is being automatically
handed down to new Follower
s.measure
- Measure in question.startHandingDown(MessageMeasure, String)
has
been called and before stopHandingDown(MessageMeasure)
.boolean isHandingDown(String id)
MessageMeasure
is being automatically
handed down to new Follower
s.id
- ID in question.startHandingDown(MessageMeasure, String)
has
been called and before stopHandingDown(String)
.boolean isStarted()
start()
has been called.boolean isStopped()
stop()
has been called.boolean start()
Follower startFollowing()
boolean startHandingDown(MessageMeasure<? extends Number,Follower> measure, String id)
Follower
from now on will immediately receive a new
MessageMetric
instance with a given ID that is using the given
measure instance.measure
- Measure to use in the newly created MessageMetric
instance.id
- The ID to locate the MessageMetric
using
MessageProducer.getMetric(String)
. No relation to the ID used
by MessageProducer.startMeasuring(MessageMeasure, String)
.boolean stop()
MessageMetric
.boolean stopFollowing(Follower follower)
follower
- This follower will receive no more messages.boolean stopHandingDown(MessageMeasure<? extends Number,Follower> measure)
startHandingDown(MessageMeasure, String)
. No further
Follower
will automatically receive MessageMetric
using
this measure by default.measure
- The measure to no longer be handing down to newly instantiated
Follower
s.boolean stopHandingDown(String id)
startHandingDown(MessageMeasure, String)
. No further
Follower
will automatically receive MessageMetric
using
this measure by default.id
- The ID of the MessageMeasure
to no longer be handing
down to newly instantiated Follower
s. No relation to
the ID used by MessageProducer.startMeasuring(MessageMeasure, String)
.Copyright © 2015. All rights reserved.