/**
 * Stream message routing — the engine's main re-entry point.
 *
 * Every message consumed from the engine stream arrives here.
 * The dispatcher inspects the message type and delegates to the
 * appropriate activity handler (Hook, Trigger, Await, Worker).
 *
 * Message types:
 *   TIMEHOOK   → Hook.processTimeHookEvent   (sleep/cron awaken)
 *   WEBHOOK    → Hook.processWebHookEvent     (signal-in awaken)
 *   TRANSITION → Activity.process             (adjacent activity)
 *   AWAIT      → Trigger.process              (child job spawn)
 *   RESULT     → Await.processEvent           (child job result)
 *   (default)  → Worker.processEvent          (worker response)
 */
import { ILogger } from '../logger';
import { JobState, JobData } from '../../types/job';
import { StreamDataResponse } from '../../types/stream';
interface DispatchContext {
    logger: ILogger;
    initActivity(topic: string, data?: JobData, context?: JobState): Promise<any>;
}
export declare function processStreamMessage(instance: DispatchContext, streamData: StreamDataResponse): Promise<void>;
export {};