All Classes and Interfaces
Class
Description
Immutable holder for adapter configuration resolved at startup.
Single source of truth for the Gson used on both sides of the adapter wire —
the outbound producer (
DefaultKafkaFactory) and the inbound commands
consumer (CommandsBootstrap).Lifecycle states observable via
NxAdapter.state() / NxAdapter.onStateChange(java.util.function.Consumer<app.l2nx.gs.adapter.core.AdapterState>).Resolves the adapter version from a classpath resource shipped inside
nx-gs-adapter-core.jar.
Stateless retry-delay generator.
Public factory for the commands consume subsystem.
Tuple of the
NxCommands façade and the optional
CommandsConsumer.Operator-tunable knobs for the built-in commands consumer.
Inbound commands consumer + dispatcher.
Bridge to the actual Kafka send.
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.Drives the platform-side connect lifecycle through a host-type-specific
HostConnectFlow strategy and emits an ConnectFlow.Outcome per logical
state transition.Coarse-grained connect-flow events surfaced to the orchestrator
(
NxAdapter).Canonical retry schedule:
30s → 1m → 2m → 5m, capped at 5m for all
subsequent attempts.Default
KafkaFactory that bridges to NxKafka.configure().build().Platform-side error response body — Gson-deserialized from 4xx / 5xx responses.
Public factory for the events publish subsystem.
Tuple of the wired-up publisher and its
NxEvents façade.Operator-tunable knobs for the built-in events publisher.
Bounded-queue + single-daemon-thread fan-out for outbound events.
Bridge to a synchronous producer flush.
Bridge to the actual Kafka send.
HostConnectFlow for gameserver host-type.Publishes a
HeartbeatEvent every 60L seconds via the
supplied HeartbeatService.KafkaPublisher on the supplied scheduler.Host-type-aware handshake strategy.
Test seam over the
NxKafka.configure().build() singleton bootstrap.Bootstraps the
nx-gs-kafka singleton from a platform-issued
KafkaCredentials.Gson
TypeAdapter for LocalizedText: reads / writes the flat
locale-keyed object form ({"en": "Great Axe", "ru": "Двуручный Топор"})
matching the platform's LocalizedText wire shape.HostConnectFlow for login-server host-type.Holds the discovered Tier-1 modules and orchestrates their lifecycle.
Adapter entry point — singleton-style facade exposing the lifecycle to the host JVM.
Session-scoped
NxGameData façade — a registry of snapshot triggers
bound by the gd-sync module during onConnect.Session-scoped
NxSync façade — per-entity NxSyncTrigger
registry plus a single NxSyncResyncHandler, populated by sync modules
during onConnect.Emits the L2NX startup wordmark and adapter version.
Outcome of one
HostConnectFlow.connect() attempt.