Class ConnectionWork

java.lang.Object

io.aether.cloud.client.Connection<io.aether.api.clientserverapi.ClientApiUnsafe, io.aether.api.clientserverapi.LoginApiRemote>

io.aether.cloud.client.ConnectionWork

All Implemented Interfaces:

io.aether.api.clientserverapi.ClientApiUnsafe, io.aether.utils.interfaces.Destroyable

public class ConnectionWork
extends Connection<io.aether.api.clientserverapi.ClientApiUnsafe, io.aether.api.clientserverapi.LoginApiRemote>
implements io.aether.api.clientserverapi.ClientApiUnsafe

Handles the specific connection logic for Work Servers, including authentication, batching of API requests, and message routing.

Field Summary

Fields

Modifier and Type	Field	Description
final AtomicLong	lastBackPing

Fields inherited from class Connection

client, connectFuture, fastMetaClient, rootApi, stateListeners, uri

Fields inherited from interface io.aether.api.clientserverapi.ClientApiUnsafe

META

Constructor Summary

Constructors

Constructor	Description
ConnectionWork(AetherCloudClient client, io.aether.api.common.ServerDescriptor s)

Method Summary

Modifier and Type	Method	Description
void	flush()
io.aether.api.common.ServerDescriptor	getServerDescriptor()
long	lifeTime()
protected void	onConnectionStateChanged(boolean isWritable)	Handles changes in the connection state.
void	scheduledWork()
void	sendSafeApiData(io.aether.api.clientserverapi.LoginClientStream data)
void	sendSafeApiDataMulti(byte backId, io.aether.api.clientserverapi.LoginClientStream data)
void	setBasic(boolean basic)
String	toString()

Methods inherited from class Connection

destroy, equals, getRootApi, getRootApiFuture, hashCode

Methods inherited from class Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

lastBackPing

public final AtomicLong lastBackPing

Constructor Details

ConnectionWork

public ConnectionWork(AetherCloudClient client,
 io.aether.api.common.ServerDescriptor s)

Method Details

onConnectionStateChanged

protected void onConnectionStateChanged(boolean isWritable)

Handles changes in the connection state. Resets the internal authentication flag and fires the state listeners to notify the client for failover logic.

Overrides:

onConnectionStateChanged in class Connection<io.aether.api.clientserverapi.ClientApiUnsafe, io.aether.api.clientserverapi.LoginApiRemote>

Parameters:

isWritable - True if the connection is active and writable, false otherwise.

sendSafeApiDataMulti

public void sendSafeApiDataMulti(byte backId,
 io.aether.api.clientserverapi.LoginClientStream data)

Specified by:

sendSafeApiDataMulti in interface io.aether.api.clientserverapi.ClientApiUnsafe

sendSafeApiData

public void sendSafeApiData(io.aether.api.clientserverapi.LoginClientStream data)

Specified by:

sendSafeApiData in interface io.aether.api.clientserverapi.ClientApiUnsafe

getServerDescriptor

public io.aether.api.common.ServerDescriptor getServerDescriptor()

toString

public String toString()

Overrides:

toString in class Object

setBasic

public void setBasic(boolean basic)

lifeTime

public long lifeTime()

scheduledWork

public void scheduledWork()

flush

public void flush()