Package app.l2nx.gs.adapter.core.connect

Class ConnectFlow

java.lang.Object

app.l2nx.gs.adapter.core.connect.ConnectFlow

All Implemented Interfaces:

Runnable

public final class ConnectFlow
extends Object
implements Runnable

Drives the POST /api/tenants/servers/connect lifecycle and emits an ConnectFlow.Outcome per logical state transition. Status-code dispatch:

• 200 → ConnectFlow.Outcome.ACTIVE
• 401 → ConnectFlow.Outcome.FAILED (terminal, no retry)
• 403 + code=GAME_SERVER_DEACTIVATED → ConnectFlow.Outcome.REJECTED (terminal, no retry)
• 409 + code=KAFKA_CREDENTIALS_MISSING → ConnectFlow.Outcome.TRANSIENT (retry via BackoffSchedule)
• 5xx / IOException → ConnectFlow.Outcome.TRANSIENT (retry via BackoffSchedule)
• any other status → ConnectFlow.Outcome.FAILED (treated as terminal so we don't hammer the platform on an unexpected response shape)

ConnectFlow.Outcome.STARTING is emitted at the top of every run (initial submit and every retry) so the orchestrator can drive the REGISTERING transition.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	ConnectFlow.Outcome	Coarse-grained connect-flow events surfaced to the orchestrator (NxAdapter).

Constructor Summary

Constructors

Constructor	Description
ConnectFlow(AdapterConfig config, ConnectClient client, BackoffSchedule backoff, ScheduledExecutorService scheduler, Consumer<ConnectFlow.Outcome> onOutcome)
ConnectFlow(AdapterConfig config, ConnectClient client, BackoffSchedule backoff, ScheduledExecutorService scheduler, Consumer<ConnectFlow.Outcome> onOutcome, Consumer<app.l2nx.gs.adapter.api.rest.ConnectResponse> onActiveResponse)

Method Summary

Modifier and Type	Method	Description
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ConnectFlow

public ConnectFlow(AdapterConfig config,
 ConnectClient client,
 BackoffSchedule backoff,
 ScheduledExecutorService scheduler,
 Consumer<ConnectFlow.Outcome> onOutcome)

ConnectFlow

public ConnectFlow(AdapterConfig config,
 ConnectClient client,
 BackoffSchedule backoff,
 ScheduledExecutorService scheduler,
 Consumer<ConnectFlow.Outcome> onOutcome,
 Consumer<app.l2nx.gs.adapter.api.rest.ConnectResponse> onActiveResponse)

Method Details

run

public void run()

Specified by:

run in interface Runnable