Interface McpSubscriptionReconciler

@ThreadSafe public interface McpSubscriptionReconciler
Thread-safe server-local control for reconciling MCP subscription authorization after application-owned invalidation or recovery.

Reconciliation includes active and establishing subscriptions, independently of their notification families or localization support. It fences delivery based on prior authorization and schedules fresh checks, or safely closes a stream when scheduling fails. It does not provide a distributed subscription registry, migrate streams, or recall bytes already handed to a transport. Distributed applications broadcast policy invalidation to every applicable server and invoke its reconciler after the current policy is available there.

Author:
Mark Allen

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    reconcileSubscriptions()
    Invalidates local authorization generations and schedules fresh checks for establishing and active subscriptions, including exact 2025-era GET streams and resource grants with no connected GET.

  • Method Details

    • reconcileSubscriptions

      void reconcileSubscriptions()
      Invalidates local authorization generations and schedules fresh checks for establishing and active subscriptions, including exact 2025-era GET streams and resource grants with no connected GET. With no subscriptions this is a harmless no-op.

      Returning confirms local delivery fencing and scheduling acceptance, not completion of authorization callbacks, replica catch-up, client delivery, or recall of bytes already written.