/**
 * Create an LT Activity Interceptor.
 *
 * HotMesh activity interceptors support both **before** and **after**
 * phases via the interruption/replay pattern:
 *
 * 1. First execution: before-phase runs → `next()` throws
 *    `DurableProxyError` → workflow pauses
 * 2. Second execution: before-phase replays → `next()` returns
 *    the stored activity result → after-phase runs
 *
 * Before phase:
 *   Injects the envelope's pre-resolved principal into headers
 *   so activities can read it via `Durable.activity.getContext()`.
 *   Skipped for `lt*` interceptor activities (they don't need identity).
 *
 * After phase:
 *   Inspects the activity result for a `milestones` field. If present,
 *   milestone events are published to the event registry.
 *
 * @see {@link https://hotmeshio.github.io/hotmesh | HotMesh docs}
 *      `services/durable/interceptor` — Activity Interceptor Replay Pattern
 */
export declare function createLTActivityInterceptor(_options?: {
    activityTaskQueue?: string;
}): {
    execute(activityCtx: {
        activityName: string;
        args: any[];
        options?: any;
    }, workflowCtx: Map<string, any>, next: () => Promise<any>): Promise<any>;
};