Package app.l2nx.gs.adapter.core.events

Class EventsConfig

java.lang.Object

app.l2nx.gs.adapter.core.events.EventsConfig

public final class EventsConfig
extends Object

Operator-tunable knobs for the built-in events publisher. Resolved by ConfigResolver.resolveEventsConfig() via the file-first source chain (l2nx.properties → JVM system property → built-in default).

Drop policy default is EventsPublisher.DropPolicy.NEWEST. EventsPublisher.DropPolicy.OLDEST is still supported but exhibits eviction contention under multi-threaded producers — head-poll and newcomer- offer are not atomic, so a hot path can over-count droppedTotal when threads race on a full queue. NEWEST drops the incoming envelope atomically via queue.offer() returning false, no eviction race.

Field Summary

Fields

Modifier and Type	Field	Description
static final EventsPublisher.DropPolicy	DEFAULT_DROP_POLICY
static final int	DEFAULT_QUEUE_CAPACITY
static final long	DEFAULT_SHUTDOWN_DRAIN_MS

Constructor Summary

Constructors

Constructor	Description
EventsConfig(int queueCapacity, EventsPublisher.DropPolicy dropPolicy, long shutdownDrainMs)

Method Summary

Modifier and Type	Method	Description
static EventsConfig	defaults()
EventsPublisher.DropPolicy	getDropPolicy()
int	getQueueCapacity()
long	getShutdownDrainMs()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

DEFAULT_QUEUE_CAPACITY

public static final int DEFAULT_QUEUE_CAPACITY

See Also:

• Constant Field Values

DEFAULT_DROP_POLICY

public static final EventsPublisher.DropPolicy DEFAULT_DROP_POLICY

DEFAULT_SHUTDOWN_DRAIN_MS

public static final long DEFAULT_SHUTDOWN_DRAIN_MS

See Also:

• Constant Field Values

Constructor Details

EventsConfig

public EventsConfig(int queueCapacity,
 EventsPublisher.DropPolicy dropPolicy,
 long shutdownDrainMs)

Method Details

defaults

public static EventsConfig defaults()

getQueueCapacity

public int getQueueCapacity()

getDropPolicy

public EventsPublisher.DropPolicy getDropPolicy()

getShutdownDrainMs

public long getShutdownDrainMs()