Class MonitoringStreamsTask
- java.lang.Object
-
- java.lang.Thread
-
- io.streamthoughts.azkarra.runtime.interceptors.monitoring.MonitoringStreamsTask
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
MonitoringStreamsTask.Reportable<T>
-
Nested classes/interfaces inherited from class java.lang.Thread
Thread.State, Thread.UncaughtExceptionHandler
-
-
Field Summary
-
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
-
-
Constructor Summary
Constructors Constructor Description MonitoringStreamsTask(String applicationId, List<MonitoringReporter> reporters, MonitoringStreamsTask.Reportable<? extends KafkaStreamsMetadata> reportable, long intervalMs)
Creates a newMonitoringStreamsTask
instance.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
offer(KafkaStreamsMetadata state)
void
run()
void
shutdown()
-
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
-
-
-
Constructor Detail
-
MonitoringStreamsTask
public MonitoringStreamsTask(String applicationId, List<MonitoringReporter> reporters, MonitoringStreamsTask.Reportable<? extends KafkaStreamsMetadata> reportable, long intervalMs)
Creates a newMonitoringStreamsTask
instance.- Parameters:
applicationId
- the application id.reporters
- the list of reporters to be used.reportable
- theMonitoringStreamsTask.Reportable
.intervalMs
- the report interval in milliseconds.
-
-
Method Detail
-
offer
public void offer(KafkaStreamsMetadata state)
-
shutdown
public void shutdown()
-
-