- java.lang.Object
-
- aeonics.entity.Entity
-
- aeonics.entity.Origin.Type
-
- aeonics.entity.Origin.NetworkClient
-
- All Implemented Interfaces:
Exportable
,Snapshotable
,java.io.Closeable
,java.lang.AutoCloseable
- Enclosing class:
- Origin
public static class Origin.NetworkClient extends Origin.Type
This class represents a data Origin that connects to a remote network endpoint to fetch data.If the connection is interrupted, this endpoint will attempt to reconnect every second (unless it is stopped).
You should implement the
connect()
method and call theOrigin.Type.emit(Message, String)
method to inject data in the system.
-
-
Constructor Summary
Constructors Constructor Description NetworkClient()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Network.Connection
connect()
Returns a server network connection.<T extends Origin.NetworkClient>
Tconnect(java.util.function.Supplier<Network.Connection> connecter)
Sets the connect function as an alternative toconnect()
.void
start()
Starts this Origin entity.void
stop()
Stops this Origin entity.-
Methods inherited from class aeonics.entity.Origin.Type
category, close, emit, start, started, started, starting, starting, stop, stopped, stopped, stopping, stopping
-
Methods inherited from class aeonics.entity.Entity
addRelation, addRelation, addRelation, cast, clearRelation, config, defineRelation, equals, export, firstRelation, hashCode, hasRelation, id, internal, name, name, onCreate, onRemove, onUpdate, parameter, relations, relationships, removeRelation, snapshot, type, valueOf, valueOf
-
-
-
-
Method Detail
-
connect
public Network.Connection connect() throws java.lang.Exception
Returns a server network connection.- Returns:
- a server network connection
- Throws:
java.lang.Exception
- if an error happens while establishing the connection
-
connect
public <T extends Origin.NetworkClient> T connect(java.util.function.Supplier<Network.Connection> connecter)
Sets the connect function as an alternative toconnect()
.- Type Parameters:
T
- this- Parameters:
connecter
- the connect function- Returns:
- this
-
start
public void start()
Description copied from class: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 classOrigin.Type
-
stop
public void stop()
Description copied from class: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 classOrigin.Type
-
-