All Classes and Interfaces
Class
Description
Immutable holder for adapter configuration resolved at startup.
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.Performs the platform-side
POST /api/tenants/servers/connect handshake.Drives the
POST /api/tenants/servers/connect lifecycle and emits an
ConnectFlow.Outcome per logical state transition.Coarse-grained connect-flow events surfaced to the orchestrator
(
NxAdapter).Outcome of a single
ConnectClient.connect(java.lang.String, java.lang.String, app.l2nx.gs.adapter.api.rest.ConnectRequest) invocation.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 the actual Kafka send.
Publishes a
HeartbeatEvent every 60L seconds via the
supplied HeartbeatService.KafkaPublisher on the supplied scheduler.JDK-only
ConnectClient backed by HttpURLConnection + Gson.Test seam over the
NxKafka.configure().build() singleton bootstrap.Bootstraps the
nx-gs-kafka singleton from a platform-issued
KafkaConfig.Holds the discovered Tier-1 modules and orchestrates their lifecycle.
Adapter entry point — singleton-style facade exposing the lifecycle to the host JVM.
Emits the L2NX startup wordmark and adapter version.