Index

A B C D E F G H I K L M N O P R S T V W
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.

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

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).

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.gamedata - package app.l2nx.gs.adapter.core.gamedata

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

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

B

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

Stateless retry-delay generator.

bindExecutor(Executor) - Method in class app.l2nx.gs.adapter.core.gamedata.NxGameDataImpl

Swap the IO executor used to run triggers.

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

clearTriggers() - Method in class app.l2nx.gs.adapter.core.gamedata.NxGameDataImpl

Drop all registered triggers.

clearTriggers() - Method in class app.l2nx.gs.adapter.core.sync.NxSyncImpl

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() - Method in class app.l2nx.gs.adapter.core.connect.GameServerConnectFlow

connect() - Method in interface app.l2nx.gs.adapter.core.connect.HostConnectFlow

Execute one handshake attempt against the platform.

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

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_PATH - Static variable in class app.l2nx.gs.adapter.core.connect.GameServerConnectFlow

CONNECT_PATH - Static variable in class app.l2nx.gs.adapter.core.connect.LoginServerConnectFlow

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

Drives the platform-side connect lifecycle through a host-type-specific HostConnectFlow strategy and emits an ConnectFlow.Outcome per logical state transition.

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

ConnectFlow(HostConnectFlow<?>, BackoffSchedule, ScheduledExecutorService, Consumer<ConnectFlow.Outcome>, Consumer<HostConnectFlow<?>>) - 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).

connectPath() - Method in class app.l2nx.gs.adapter.core.connect.GameServerConnectFlow

connectPath() - Method in interface app.l2nx.gs.adapter.core.connect.HostConnectFlow

The path under platformUrl this flow POSTs to — exposed for test introspection and logging.

connectPath() - Method in class app.l2nx.gs.adapter.core.connect.LoginServerConnectFlow

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

create() - Static method in class app.l2nx.gs.adapter.core.kafka.AdapterGson

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_HOST_TYPE - Static variable in class app.l2nx.gs.adapter.core.config.AdapterConfig

Default host-type when no l2nx.host-type is configured — preserves back-compat for pre-host-type adapter deployments.

DEFAULT_IO_WORKERS_MIN - Static variable in class app.l2nx.gs.adapter.core.config.AdapterConfig

Floor for the IO worker pool — keeps modules/handlers usable when host JVM reports a single available processor.

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

defaultIoWorkers() - Static method in class app.l2nx.gs.adapter.core.config.AdapterConfig

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(Map<String, String>, EventsPublisher.Sender, EventsPublisher.ProducerFlusher, EventsConfig, EventTypeRegistry) - Constructor for class app.l2nx.gs.adapter.core.events.EventsPublisher

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

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

Bridge to a synchronous producer flush.

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.

flush() - Method in interface app.l2nx.gs.adapter.core.events.EventsPublisher.ProducerFlusher

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

Synchronously drain the queue into the sender and block on a producer flush until in-flight records reach the broker, or timeoutMs elapses.

G

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

HostConnectFlow for gameserver host-type.

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

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.TypedConnectOutcome

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

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

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

Adapter host-type — gs (game server) or ls (login server).

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

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

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.TypedConnectOutcome

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.TypedConnectOutcome

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

heartbeatTopic() - Method in class app.l2nx.gs.adapter.core.connect.GameServerConnectFlow

heartbeatTopic() - Method in interface app.l2nx.gs.adapter.core.connect.HostConnectFlow

Heartbeat Kafka topic from the captured response.

heartbeatTopic() - Method in class app.l2nx.gs.adapter.core.connect.LoginServerConnectFlow

HostConnectFlow<R> - Interface in app.l2nx.gs.adapter.core.connect

Host-type-aware handshake strategy.

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.TypedConnectOutcome

I

init(KafkaCredentials, 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.TypedConnectOutcome

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.TypedConnectOutcome

K

kafka() - Method in class app.l2nx.gs.adapter.core.connect.GameServerConnectFlow

kafka() - Method in interface app.l2nx.gs.adapter.core.connect.HostConnectFlow

Kafka client bootstrap credentials from the captured response.

kafka() - Method in class app.l2nx.gs.adapter.core.connect.LoginServerConnectFlow

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 KafkaCredentials.

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

L

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

Gson TypeAdapter for LocalizedText: reads / writes the flat locale-keyed object form ({"en": "Great Axe", "ru": "Двуручный Топор"}) matching the platform's LocalizedText wire shape.

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

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

HostConnectFlow for login-server host-type.

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

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.

NxGameDataImpl - Class in app.l2nx.gs.adapter.core.gamedata

Session-scoped NxGameData façade — a registry of snapshot triggers bound by the gd-sync module during onConnect.

NxGameDataImpl() - Constructor for class app.l2nx.gs.adapter.core.gamedata.NxGameDataImpl

NxSyncImpl - Class in app.l2nx.gs.adapter.core.sync

Session-scoped NxSync façade — per-entity NxSyncTrigger registry plus a single NxSyncResyncHandler, populated by sync modules during onConnect.

NxSyncImpl() - Constructor for class app.l2nx.gs.adapter.core.sync.NxSyncImpl

O

ok(R) - Static method in class app.l2nx.gs.adapter.core.connect.TypedConnectOutcome

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

publishSnapshot() - Method in class app.l2nx.gs.adapter.core.gamedata.NxGameDataImpl

R

read(JsonReader) - Method in class app.l2nx.gs.adapter.core.kafka.LocalizedTextTypeAdapter

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

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

registerResyncHandler(NxSyncResyncHandler) - Method in class app.l2nx.gs.adapter.core.sync.NxSyncImpl

registerSnapshotTrigger(NxGameDataTrigger) - Method in class app.l2nx.gs.adapter.core.gamedata.NxGameDataImpl

registerTrigger(String, NxSyncTrigger) - Method in class app.l2nx.gs.adapter.core.sync.NxSyncImpl

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.

requestNow(String, long) - Method in class app.l2nx.gs.adapter.core.sync.NxSyncImpl

requestNow(String, Collection<Long>) - Method in class app.l2nx.gs.adapter.core.sync.NxSyncImpl

requestResync(String, Collection<Long>, boolean) - Method in class app.l2nx.gs.adapter.core.sync.NxSyncImpl

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

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

Host-type — selects which connect endpoint the adapter targets and which server-key property name is required.

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

resolveIoWorkers() - 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

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

Resolve the server key matching the host-type.

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

response() - Method in class app.l2nx.gs.adapter.core.connect.GameServerConnectFlow

response() - Method in interface app.l2nx.gs.adapter.core.connect.HostConnectFlow

Captured response from the last successful HostConnectFlow.connect().

response() - Method in class app.l2nx.gs.adapter.core.connect.LoginServerConnectFlow

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

S

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

serverId() - Method in class app.l2nx.gs.adapter.core.connect.GameServerConnectFlow

serverId() - Method in interface app.l2nx.gs.adapter.core.connect.HostConnectFlow

serverId() - Method in class app.l2nx.gs.adapter.core.connect.LoginServerConnectFlow

serverName() - Method in class app.l2nx.gs.adapter.core.connect.GameServerConnectFlow

serverName() - Method in interface app.l2nx.gs.adapter.core.connect.HostConnectFlow

serverName() - Method in class app.l2nx.gs.adapter.core.connect.LoginServerConnectFlow

serverSlug() - Method in class app.l2nx.gs.adapter.core.connect.GameServerConnectFlow

serverSlug() - Method in interface app.l2nx.gs.adapter.core.connect.HostConnectFlow

serverSlug() - Method in class app.l2nx.gs.adapter.core.connect.LoginServerConnectFlow

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() - 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, KafkaCredentials, String, String, UUID, Executor, Executor, NxEvents, NxSync, 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, EventsPublisher.ProducerFlusher, 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

swap(NxCommands, MessagingTopics, KafkaCredentials, String, String, UUID, Executor, Executor, NxEvents, NxSync, CommandsConsumer.ReplySender, CommandsConfig) - Static method in class app.l2nx.gs.adapter.core.commands.CommandsBootstrap

Rebuild the consumer in-place behind an existing NxCommands façade, preserving its registered handlers across reconnect.

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

Rebuild the publisher in-place behind a stable NxEvents façade.

syncTopics() - Method in class app.l2nx.gs.adapter.core.connect.GameServerConnectFlow

syncTopics() - Method in interface app.l2nx.gs.adapter.core.connect.HostConnectFlow

Sync-stream topic bundle (db / runtime / datapack).

syncTopics() - Method in class app.l2nx.gs.adapter.core.connect.LoginServerConnectFlow

T

tenantId() - Method in class app.l2nx.gs.adapter.core.connect.GameServerConnectFlow

tenantId() - Method in interface app.l2nx.gs.adapter.core.connect.HostConnectFlow

tenantId() - Method in class app.l2nx.gs.adapter.core.connect.LoginServerConnectFlow

tenantSlug() - Method in class app.l2nx.gs.adapter.core.connect.GameServerConnectFlow

tenantSlug() - Method in interface app.l2nx.gs.adapter.core.connect.HostConnectFlow

tenantSlug() - Method in class app.l2nx.gs.adapter.core.connect.LoginServerConnectFlow

topics() - Method in class app.l2nx.gs.adapter.core.connect.GameServerConnectFlow

topics() - Method in interface app.l2nx.gs.adapter.core.connect.HostConnectFlow

Messaging topic bundle (events + commands) from the captured response.

topics() - Method in class app.l2nx.gs.adapter.core.connect.LoginServerConnectFlow

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

Transient failure — retry scheduled.

TypedConnectOutcome<R> - Class in app.l2nx.gs.adapter.core.connect

Outcome of one HostConnectFlow.connect() attempt.

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.

W

write(JsonWriter, LocalizedText) - Method in class app.l2nx.gs.adapter.core.kafka.LocalizedTextTypeAdapter

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