Index

A B C D E F G H I K M N O P R S T V
All Classes and Interfaces|All Packages|Constant Field Values

A

ACTIVE - Enum constant in enum class app.l2nx.gs.adapter.core.AdapterState

Connected, heartbeat running.

ACTIVE - Enum constant in enum class app.l2nx.gs.adapter.core.connect.ConnectFlow.Outcome

200 — adapter is connected.

AdapterConfig - Class in app.l2nx.gs.adapter.core.config

Immutable holder for adapter configuration resolved at startup.

AdapterState - Enum Class in app.l2nx.gs.adapter.core

Lifecycle states observable via NxAdapter.state() / NxAdapter.onStateChange(java.util.function.Consumer<app.l2nx.gs.adapter.core.AdapterState>).

AdapterVersion - Class in app.l2nx.gs.adapter.core.lifecycle

Resolves the adapter version from a classpath resource shipped inside nx-gs-adapter-core.jar.

app.l2nx.gs.adapter.core - package app.l2nx.gs.adapter.core

app.l2nx.gs.adapter.core.commands - package app.l2nx.gs.adapter.core.commands

app.l2nx.gs.adapter.core.config - package app.l2nx.gs.adapter.core.config

app.l2nx.gs.adapter.core.connect - package app.l2nx.gs.adapter.core.connect

app.l2nx.gs.adapter.core.events - package app.l2nx.gs.adapter.core.events

app.l2nx.gs.adapter.core.heartbeat - package app.l2nx.gs.adapter.core.heartbeat

app.l2nx.gs.adapter.core.kafka - package app.l2nx.gs.adapter.core.kafka

app.l2nx.gs.adapter.core.lifecycle - package app.l2nx.gs.adapter.core.lifecycle

app.l2nx.gs.adapter.core.modules - package app.l2nx.gs.adapter.core.modules

B

BackoffSchedule - Interface in app.l2nx.gs.adapter.core.connect

Stateless retry-delay generator.

build(String, String, Map<String, Object>, Map<String, byte[]>, Consumer<KafkaState>) - Method in class app.l2nx.gs.adapter.core.kafka.DefaultKafkaFactory

build(String, String, Map<String, Object>, Map<String, byte[]>, Consumer<KafkaState>) - Method in interface app.l2nx.gs.adapter.core.kafka.KafkaFactory

Create or replace the NxKafka singleton with this configuration.

buildJaas(String, String) - Static method in class app.l2nx.gs.adapter.core.kafka.KafkaInitializer

C

CLOSED - Enum constant in enum class app.l2nx.gs.adapter.core.AdapterState

Terminal — JVM shutdown hook fired or NxAdapter.shutdown() called.

commands() - Method in class app.l2nx.gs.adapter.core.commands.CommandsBootstrap.Started

CommandsBootstrap - Class in app.l2nx.gs.adapter.core.commands

Public factory for the commands consume subsystem.

CommandsBootstrap.Started - Class in app.l2nx.gs.adapter.core.commands

Tuple of the NxCommands façade and the optional CommandsConsumer.

CommandsConfig - Class in app.l2nx.gs.adapter.core.commands

Operator-tunable knobs for the built-in commands consumer.

CommandsConfig(long, long, long, long, Map<String, Object>) - Constructor for class app.l2nx.gs.adapter.core.commands.CommandsConfig

CommandsConsumer - Class in app.l2nx.gs.adapter.core.commands

Inbound commands consumer + dispatcher.

CommandsConsumer.ReplySender - Interface in app.l2nx.gs.adapter.core.commands

Bridge to the actual Kafka send.

ConfigResolver - Class in app.l2nx.gs.adapter.core.config

Resolves adapter configuration from a two-source chain (per key), file-first: Properties file — either the path given by -Dl2nx.config-file=<path> (operator-preferred; absolute or relative to the JVM working directory), or l2nx.properties in the JVM working directory of the host application as a fallback when l2nx.config-file is unset. JVM system property (e.g.

ConfigResolver() - Constructor for class app.l2nx.gs.adapter.core.config.ConfigResolver

connect(ConnectContext) - Method in class app.l2nx.gs.adapter.core.modules.ModuleRegistry

Two-phase connect: invoke onConnect(ctx) on every module, then iterate again invoking start() on every module that survived its onConnect.

connect(String, String, ConnectRequest) - Method in interface app.l2nx.gs.adapter.core.connect.ConnectClient

Send the connect request and return a typed result.

connect(String, String, ConnectRequest) - Method in class app.l2nx.gs.adapter.core.connect.HttpURLConnectionConnectClient

ConnectClient - Interface in app.l2nx.gs.adapter.core.connect

Performs the platform-side POST /api/tenants/servers/connect handshake.

ConnectFlow - Class in app.l2nx.gs.adapter.core.connect

Drives the POST /api/tenants/servers/connect lifecycle and emits an ConnectFlow.Outcome per logical state transition.

ConnectFlow(AdapterConfig, ConnectClient, BackoffSchedule, ScheduledExecutorService, Consumer<ConnectFlow.Outcome>) - Constructor for class app.l2nx.gs.adapter.core.connect.ConnectFlow

ConnectFlow(AdapterConfig, ConnectClient, BackoffSchedule, ScheduledExecutorService, Consumer<ConnectFlow.Outcome>, Consumer<ConnectResponse>) - Constructor for class app.l2nx.gs.adapter.core.connect.ConnectFlow

ConnectFlow.Outcome - Enum Class in app.l2nx.gs.adapter.core.connect

Coarse-grained connect-flow events surfaced to the orchestrator (NxAdapter).

ConnectResult - Class in app.l2nx.gs.adapter.core.connect

Outcome of a single ConnectClient.connect(java.lang.String, java.lang.String, app.l2nx.gs.adapter.api.rest.ConnectRequest) invocation.

consumer() - Method in class app.l2nx.gs.adapter.core.commands.CommandsBootstrap.Started

currentStatus() - Method in class app.l2nx.gs.adapter.core.commands.CommandsConsumer

Heartbeat slot snapshot for the commands module.

currentStatus() - Method in class app.l2nx.gs.adapter.core.events.EventsPublisher

Build a heartbeat slot snapshot.

currentStatuses() - Method in class app.l2nx.gs.adapter.core.modules.ModuleRegistry

Snapshot of ModuleStatus per discovered module.

D

DEFAULT_DROP_POLICY - Static variable in class app.l2nx.gs.adapter.core.events.EventsConfig

DEFAULT_HOST_SYNC_TIMEOUT_MS - Static variable in class app.l2nx.gs.adapter.core.commands.CommandsConfig

Bound on ctx.host().sync(...) await — high enough that a healthy host pool succeeds, low enough that a stuck pool surfaces as a typed HostExecutorTimeoutException rather than a wedged consumer thread.

DEFAULT_POLL_TIMEOUT_MS - Static variable in class app.l2nx.gs.adapter.core.commands.CommandsConfig

DEFAULT_QUEUE_CAPACITY - Static variable in class app.l2nx.gs.adapter.core.events.EventsConfig

DEFAULT_REPLY_FLUSH_TIMEOUT_MS - Static variable in class app.l2nx.gs.adapter.core.commands.CommandsConfig

Bound on the per-batch reply-flush wait between handler completion and Kafka offset commit.

DEFAULT_SHUTDOWN_DRAIN_MS - Static variable in class app.l2nx.gs.adapter.core.events.EventsConfig

DEFAULT_SHUTDOWN_TIMEOUT_MS - Static variable in class app.l2nx.gs.adapter.core.commands.CommandsConfig

DefaultBackoffSchedule - Class in app.l2nx.gs.adapter.core.connect

Canonical retry schedule: 30s → 1m → 2m → 5m, capped at 5m for all subsequent attempts.

DefaultBackoffSchedule() - Constructor for class app.l2nx.gs.adapter.core.connect.DefaultBackoffSchedule

DefaultKafkaFactory - Class in app.l2nx.gs.adapter.core.kafka

Default KafkaFactory that bridges to NxKafka.configure().build().

DefaultKafkaFactory() - Constructor for class app.l2nx.gs.adapter.core.kafka.DefaultKafkaFactory

defaults() - Static method in class app.l2nx.gs.adapter.core.commands.CommandsConfig

defaults() - Static method in class app.l2nx.gs.adapter.core.events.EventsConfig

DEGRADED - Enum constant in enum class app.l2nx.gs.adapter.core.AdapterState

Transient failure (5xx / 409 / network) — retry scheduled.

DISABLED - Enum constant in enum class app.l2nx.gs.adapter.core.AdapterState

Adapter is loaded but l2nx.enabled=false — no work performed.

discover() - Method in class app.l2nx.gs.adapter.core.modules.ModuleRegistry

Run ServiceLoader.load(Class) for AdapterModule on adapter-core's own classloader (avoiding host-CL surprises on JVMs with non-trivial classloader hierarchies) and cache the result, sorted by AdapterModule.name().

E

emit(NxLog, String) - Static method in class app.l2nx.gs.adapter.core.lifecycle.StartupBanner

enqueue(EventEnvelope) - Method in class app.l2nx.gs.adapter.core.events.EventsPublisher

Append an envelope to the publish queue.

ErrorEnvelope - Class in app.l2nx.gs.adapter.core.connect

Platform-side error response body — Gson-deserialized from 4xx / 5xx responses.

ErrorEnvelope(String, String) - Constructor for class app.l2nx.gs.adapter.core.connect.ErrorEnvelope

events() - Method in class app.l2nx.gs.adapter.core.events.EventsBootstrap.Started

EventsBootstrap - Class in app.l2nx.gs.adapter.core.events

Public factory for the events publish subsystem.

EventsBootstrap.Started - Class in app.l2nx.gs.adapter.core.events

Tuple of the wired-up publisher and its NxEvents façade.

EventsConfig - Class in app.l2nx.gs.adapter.core.events

Operator-tunable knobs for the built-in events publisher.

EventsConfig(int, EventsPublisher.DropPolicy, long) - Constructor for class app.l2nx.gs.adapter.core.events.EventsConfig

EventsPublisher - Class in app.l2nx.gs.adapter.core.events

Bounded-queue + single-daemon-thread fan-out for outbound events.

EventsPublisher(Map<String, String>, EventsPublisher.Sender, EventsConfig, EventTypeRegistry) - Constructor for class app.l2nx.gs.adapter.core.events.EventsPublisher

EventsPublisher.DropPolicy - Enum Class in app.l2nx.gs.adapter.core.events

EventsPublisher.Sender - Interface in app.l2nx.gs.adapter.core.events

Bridge to the actual Kafka send.

F

FAILED - Enum constant in enum class app.l2nx.gs.adapter.core.AdapterState

Terminal failure due to config error or 401 (invalid server-key).

FAILED - Enum constant in enum class app.l2nx.gs.adapter.core.connect.ConnectFlow.Outcome

Terminal non-recoverable failure — no further retries.

G

getAdapterVersion() - Method in class app.l2nx.gs.adapter.core.config.AdapterConfig

getCode() - Method in class app.l2nx.gs.adapter.core.connect.ErrorEnvelope

getCommands() - Method in class app.l2nx.gs.adapter.core.config.AdapterConfig

getDropPolicy() - Method in class app.l2nx.gs.adapter.core.events.EventsConfig

getError() - Method in class app.l2nx.gs.adapter.core.connect.ConnectResult

getEvents() - Method in class app.l2nx.gs.adapter.core.config.AdapterConfig

getHostSyncTimeoutMs() - Method in class app.l2nx.gs.adapter.core.commands.CommandsConfig

getIoException() - Method in class app.l2nx.gs.adapter.core.connect.ConnectResult

getKafkaOverrides() - Method in class app.l2nx.gs.adapter.core.commands.CommandsConfig

getKafkaProducerOverrides() - Method in class app.l2nx.gs.adapter.core.config.AdapterConfig

getMessage() - Method in class app.l2nx.gs.adapter.core.connect.ErrorEnvelope

getPlatformUrl() - Method in class app.l2nx.gs.adapter.core.config.AdapterConfig

getPollTimeoutMs() - Method in class app.l2nx.gs.adapter.core.commands.CommandsConfig

getQueueCapacity() - Method in class app.l2nx.gs.adapter.core.events.EventsConfig

getReplyFlushTimeoutMs() - Method in class app.l2nx.gs.adapter.core.commands.CommandsConfig

getResponse() - Method in class app.l2nx.gs.adapter.core.connect.ConnectResult

getServerKey() - Method in class app.l2nx.gs.adapter.core.config.AdapterConfig

getShutdownDrainMs() - Method in class app.l2nx.gs.adapter.core.events.EventsConfig

getShutdownTimeoutMs() - Method in class app.l2nx.gs.adapter.core.commands.CommandsConfig

getStatusCode() - Method in class app.l2nx.gs.adapter.core.connect.ConnectResult

H

HeartbeatService - Class in app.l2nx.gs.adapter.core.heartbeat

Publishes a HeartbeatEvent every 60L seconds via the supplied HeartbeatService.KafkaPublisher on the supplied scheduler.

HeartbeatService(HeartbeatService.KafkaPublisher, ScheduledExecutorService, String, Supplier<List<ModuleStatus>>) - Constructor for class app.l2nx.gs.adapter.core.heartbeat.HeartbeatService

HeartbeatService.KafkaPublisher - Interface in app.l2nx.gs.adapter.core.heartbeat

hostExecutor(Executor) - Static method in class app.l2nx.gs.adapter.core.NxAdapter

Register the host's game-side Executor for command-handler ctx.host().sync(...) / .async(...) hops.

httpError(int, ErrorEnvelope) - Static method in class app.l2nx.gs.adapter.core.connect.ConnectResult

HttpURLConnectionConnectClient - Class in app.l2nx.gs.adapter.core.connect

JDK-only ConnectClient backed by HttpURLConnection + Gson.

HttpURLConnectionConnectClient() - Constructor for class app.l2nx.gs.adapter.core.connect.HttpURLConnectionConnectClient

I

init(KafkaConfig, String, Map<String, byte[]>, Consumer<KafkaState>) - Method in class app.l2nx.gs.adapter.core.kafka.KafkaInitializer

Build the Kafka client and return the post-build state.

INIT - Enum constant in enum class app.l2nx.gs.adapter.core.AdapterState

Initial state before NxAdapter.start() runs.

ioFailure(IOException) - Static method in class app.l2nx.gs.adapter.core.connect.ConnectResult

isEnabled() - Method in class app.l2nx.gs.adapter.core.config.AdapterConfig

isFamilyEnabled(String) - Method in class app.l2nx.gs.adapter.core.events.EventsPublisher

True when the family key has a non-empty topic configured.

isIoFailure() - Method in class app.l2nx.gs.adapter.core.connect.ConnectResult

K

KafkaFactory - Interface in app.l2nx.gs.adapter.core.kafka

Test seam over the NxKafka.configure().build() singleton bootstrap.

KafkaInitializer - Class in app.l2nx.gs.adapter.core.kafka

Bootstraps the nx-gs-kafka singleton from a platform-issued KafkaConfig.

KafkaInitializer(KafkaFactory) - Constructor for class app.l2nx.gs.adapter.core.kafka.KafkaInitializer

KafkaInitializer(KafkaFactory, Map<String, Object>) - Constructor for class app.l2nx.gs.adapter.core.kafka.KafkaInitializer

M

ModuleRegistry - Class in app.l2nx.gs.adapter.core.modules

Holds the discovered Tier-1 modules and orchestrates their lifecycle.

ModuleRegistry() - Constructor for class app.l2nx.gs.adapter.core.modules.ModuleRegistry

modules() - Method in class app.l2nx.gs.adapter.core.modules.ModuleRegistry

Test seam / debugging accessor — returns the discovered modules in name-sorted order.

N

NEWEST - Enum constant in enum class app.l2nx.gs.adapter.core.events.EventsPublisher.DropPolicy

next(int) - Method in interface app.l2nx.gs.adapter.core.connect.BackoffSchedule

next(int) - Method in class app.l2nx.gs.adapter.core.connect.DefaultBackoffSchedule

NxAdapter - Class in app.l2nx.gs.adapter.core

Adapter entry point — singleton-style facade exposing the lifecycle to the host JVM.

O

OLDEST - Enum constant in enum class app.l2nx.gs.adapter.core.events.EventsPublisher.DropPolicy

onStateChange(Consumer<AdapterState>) - Static method in class app.l2nx.gs.adapter.core.NxAdapter

Register a state-transition callback.

P

publisher() - Method in class app.l2nx.gs.adapter.core.events.EventsBootstrap.Started

R

REGISTERING - Enum constant in enum class app.l2nx.gs.adapter.core.AdapterState

Connect attempt in flight (first attempt, or any retry).

REJECTED - Enum constant in enum class app.l2nx.gs.adapter.core.AdapterState

Terminal — server deactivated by tenant (403 GAME_SERVER_DEACTIVATED).

REJECTED - Enum constant in enum class app.l2nx.gs.adapter.core.connect.ConnectFlow.Outcome

Terminal — server deactivated by tenant.

resolve() - Method in class app.l2nx.gs.adapter.core.config.ConfigResolver

resolve() - Static method in class app.l2nx.gs.adapter.core.lifecycle.AdapterVersion

resolveAdapterVersion() - Method in class app.l2nx.gs.adapter.core.config.ConfigResolver

resolveBoolean(String, boolean) - Method in class app.l2nx.gs.adapter.core.config.ConfigResolver

resolveCommandsConfig() - Method in class app.l2nx.gs.adapter.core.config.ConfigResolver

resolveEnabled() - Method in class app.l2nx.gs.adapter.core.config.ConfigResolver

resolveEventsConfig() - Method in class app.l2nx.gs.adapter.core.config.ConfigResolver

resolvePlatformUrl() - Method in class app.l2nx.gs.adapter.core.config.ConfigResolver

resolveServerKey() - Method in class app.l2nx.gs.adapter.core.config.ConfigResolver

resolveString(String) - Method in class app.l2nx.gs.adapter.core.config.ConfigResolver

run() - Method in class app.l2nx.gs.adapter.core.connect.ConnectFlow

S

SCRAM_LOGIN_MODULE - Static variable in class app.l2nx.gs.adapter.core.kafka.KafkaInitializer

send(String, String, Object) - Method in interface app.l2nx.gs.adapter.core.heartbeat.HeartbeatService.KafkaPublisher

send(ProducerRecord<byte[], Object>, Callback) - Method in interface app.l2nx.gs.adapter.core.commands.CommandsConsumer.ReplySender

send(ProducerRecord<byte[], Object>, Callback) - Method in interface app.l2nx.gs.adapter.core.events.EventsPublisher.Sender

shutdown() - Method in class app.l2nx.gs.adapter.core.modules.ModuleRegistry

Reverse-discovery-order shutdown: invoke stop() on every module, then iterate again invoking onDisconnect().

shutdown() - Method in class app.l2nx.gs.adapter.core.NxAdapter

Idempotent shutdown — cancel heartbeat, cancel connect scheduler, shut down the Kafka client if alive, and transition to AdapterState.CLOSED.

start() - Method in class app.l2nx.gs.adapter.core.commands.CommandsConsumer

Spawn the consumer daemon and subscribe to inboundTopic.

start() - Method in class app.l2nx.gs.adapter.core.events.EventsPublisher

Spawn the publisher daemon.

start() - Static method in class app.l2nx.gs.adapter.core.NxAdapter

Resolve config and (if enabled) initiate the connect flow on a daemon scheduler.

start(MessagingTopics, KafkaConfig, String, Executor, NxEvents, CommandsConsumer.ReplySender, CommandsConfig) - Static method in class app.l2nx.gs.adapter.core.commands.CommandsBootstrap

Wire up the registry, the NxCommands façade, and (when messagingTopics.commandsTopic is configured) a Kafka consumer + daemon thread.

start(Map<String, String>, EventsPublisher.Sender, EventsConfig) - Static method in class app.l2nx.gs.adapter.core.events.EventsBootstrap

Materializes the registry, instantiates the publisher, starts its daemon thread, and wraps the publisher in an NxEvents façade.

start(String, String, String, String, String, String) - Method in class app.l2nx.gs.adapter.core.heartbeat.HeartbeatService

STARTING - Enum constant in enum class app.l2nx.gs.adapter.core.connect.ConnectFlow.Outcome

A connect attempt is about to be executed (initial submit or retry).

StartupBanner - Class in app.l2nx.gs.adapter.core.lifecycle

Emits the L2NX startup wordmark and adapter version.

state() - Static method in class app.l2nx.gs.adapter.core.NxAdapter

Current adapter state.

stop() - Method in class app.l2nx.gs.adapter.core.commands.CommandsConsumer

Signal the daemon to stop, wake it from any blocking poll, await join up to shutdownTimeoutMs, then close the Kafka consumer.

stop() - Method in class app.l2nx.gs.adapter.core.events.EventsPublisher

Stop the publisher.

stop() - Method in class app.l2nx.gs.adapter.core.heartbeat.HeartbeatService

success(ConnectResponse) - Static method in class app.l2nx.gs.adapter.core.connect.ConnectResult

T

TRANSIENT - Enum constant in enum class app.l2nx.gs.adapter.core.connect.ConnectFlow.Outcome

Transient failure — retry scheduled.

V

valueOf(String) - Static method in enum class app.l2nx.gs.adapter.core.AdapterState

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class app.l2nx.gs.adapter.core.connect.ConnectFlow.Outcome

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class app.l2nx.gs.adapter.core.events.EventsPublisher.DropPolicy

Returns the enum constant of this class with the specified name.

values() - Static method in enum class app.l2nx.gs.adapter.core.AdapterState

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class app.l2nx.gs.adapter.core.connect.ConnectFlow.Outcome

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class app.l2nx.gs.adapter.core.events.EventsPublisher.DropPolicy

Returns an array containing the constants of this enum class, in the order they are declared.

A B C D E F G H I K M N O P R S T V
All Classes and Interfaces|All Packages|Constant Field Values