- java.lang.Object
-
- aeonics.entity.Entity
-
- aeonics.entity.Step.Type
-
- aeonics.entity.Step.Origin.Type
-
- aeonics.entity.Step.Origin.Background
-
- All Implemented Interfaces:
Exportable
,Snapshotable
,java.io.Closeable
,java.lang.AutoCloseable
,java.lang.Runnable
- Enclosing class:
- Step.Origin
public static class Step.Origin.Background extends Step.Origin.Type implements java.lang.Runnable
This class represents a data Origin that runs in the background in order to collect data and inject it in the system.You should implement the
run()
method and call theStep.Origin.Type.produce(Message, String)
method to inject data in the system.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface aeonics.util.Snapshotable
Snapshotable.SnapshotMode
-
-
Constructor Summary
Constructors Constructor Description Background()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
run()
Collects data in the background and callsStep.Type.emit(Message, String)
method to inject data in the system.<T extends Step.Origin.Background>
Trun(java.lang.Runnable runner)
Sets the run function as an alternative torun()
.void
start()
Starts this Origin entity.void
stop()
Stops this Origin entity.-
Methods inherited from class aeonics.entity.Step.Origin.Type
close, produce, start, started, started, starting, starting, stop, stopped, stopped, stopping, stopping
-
Methods inherited from class aeonics.entity.Entity
addRelation, addRelation, addRelation, cast, clearRelation, config, context, countRelations, countRelations, defineRelation, equals, export, firstRelation, hashCode, hasRelation, id, internal, internal, name, name, onCreate, onRemove, onUpdate, parameter, relations, relationships, removeRelation, snapshot, snapshotMode, template, type, valueOf, valueOf
-
-
-
-
Method Detail
-
run
public <T extends Step.Origin.Background> T run(java.lang.Runnable runner)
Sets the run function as an alternative torun()
.- Type Parameters:
T
- this- Parameters:
runner
- the run function- Returns:
- this
-
run
public void run()
Collects data in the background and callsStep.Type.emit(Message, String)
method to inject data in the system.- Specified by:
run
in interfacejava.lang.Runnable
-
start
public void start()
Description copied from class:Step.Origin.Type
Starts this Origin entity. The Origin can only be started if it is currently stopped, otherwise it does nothing. Implementations are responsible to set and maintain the internal state.- Overrides:
start
in classStep.Origin.Type
-
stop
public void stop()
Description copied from class:Step.Origin.Type
Stops this Origin entity. The Origin can only be stopped if it is currently running, otherwise it does nothing. Implementations are responsible to set and maintain the internal state.- Overrides:
stop
in classStep.Origin.Type
-
-