ProcessorRegistry

This docs was updated at: 2026-02-23

com.paragon.telemetry.processors.ProcessorRegistry  ·  Record

---

Registry for managing multiple telemetry processors. Broadcasts events to all registered processors.

This replaces the old OpenTelemetryVendors class with a cleaner API and proper lifecycle management.

Methods

empty

public static @NonNull ProcessorRegistry empty()

Creates an empty registry.

---

of

public static @NonNull ProcessorRegistry of(@NonNull List<TelemetryProcessor> processors)

Creates a registry with the given processors.

---

of

public static @NonNull ProcessorRegistry of(@NonNull TelemetryProcessor processor)

Creates a registry with a single processor.

---

broadcast

public void broadcast(@NonNull TelemetryEvent event)

Broadcasts an event to all registered processors. This is fire-and-forget - it does not wait for processing.

Parameters

Name	Description
event	the event to broadcast

---

flushAll

public boolean flushAll(long timeout, @NonNull TimeUnit unit)

Flushes all processors.

Parameters

Name	Description
timeout	max time to wait for each processor
unit	time unit

Returns

true if all processors flushed successfully

---

shutdown

public void shutdown()

Shuts down all registered processors gracefully.

---

hasProcessors

public boolean hasProcessors()

Returns whether any processors are registered.

---

size

public int size()

Returns the number of registered processors.