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 the JAR manifest's
Implementation-Version.Stateless retry-delay generator.
Resolves adapter configuration from a two-source chain (per key), file-first:
Properties file — either the absolute path given by
-Dl2nx.config-file=<path> (operator-preferred), or the classpath resource
l2nx.properties 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.
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.Adapter entry point — singleton-style facade exposing the lifecycle to the host JVM.
Emits the L2NX startup wordmark and adapter version.