Class JdbcDispatchSubscriber

java.lang.Object

ai.pipestream.module.pipelineprobe.pipelinecrawl.JdbcDispatchSubscriber

@ApplicationScoped
public class JdbcDispatchSubscriber
extends Object

Subscribes to the JDBC connector's streamCrawlStatus server-streaming RPC and hydrates a RunLedger from the per-event payload.

Three event types matter:

• JdbcCrawlEventType.JDBC_CRAWL_EVENT_TYPE_EXPECTED_COUNT_KNOWN — sets RunLedger.setExpectedRowCount(int).
• JdbcCrawlEventType.JDBC_CRAWL_EVENT_TYPE_DOC_DISPATCHED — adds the emitted_doc_id to RunLedger.recordDispatched(String).
• JdbcCrawlEventType.JDBC_CRAWL_EVENT_TYPE_DISPATCH_COMPLETE — flips RunLedger.markDispatchComplete().

Other event types (COMPLETION, DELETE, sub-crawl progress with event_type=UNSPECIFIED) are ignored — they're informational for other consumers but don't affect the ledger.

The subscription runs in its own gRPC Context.CancellableContext so the orchestrator can cancel cleanly via JdbcDispatchSubscriber.Subscription.cancel() regardless of whether the connector has closed the stream.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	JdbcDispatchSubscriber.Subscription	The active subscription.

Constructor Summary

Constructors

Constructor	Description
JdbcDispatchSubscriber()	Creates the JDBC dispatch subscriber.

Method Summary

Modifier and Type	Method	Description
JdbcDispatchSubscriber.Subscription	subscribe(String triggerId, RunLedger ledger)	Open a subscription against triggerId.

Methods inherited from class Object

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

Constructor Details

JdbcDispatchSubscriber

public JdbcDispatchSubscriber()

Creates the JDBC dispatch subscriber. Managed by CDI.

Method Details

subscribe

public JdbcDispatchSubscriber.Subscription subscribe(String triggerId,
 RunLedger ledger)

Open a subscription against triggerId. Events stream into ledger. Caller must JdbcDispatchSubscriber.Subscription.cancel() when the run terminates regardless of outcome.

Parameters:

triggerId - the connector trigger id to stream crawl status for; must be non-empty

ledger - the RunLedger hydrated from the streamed events; must be non-null

Returns:

the live JdbcDispatchSubscriber.Subscription, which the caller must cancel when the run terminates

Throws:

IllegalArgumentException - if triggerId is null/empty or ledger is null