/// <reference types="node" />
import { Worker } from "cluster";
import { IPCManager, IPCParams, IProcessState, ProcessListener } from "..";
import { IWorkerMessage } from "./master";
/**
 * IPC interface for worker node
 */
export interface IMasterMessage {
    channel: string;
    data?: any;
}
export declare class IPCWorker<T extends IProcessState = any> extends IPCManager<T> {
    worker: Worker;
    listeners: {
        [channel: string]: ProcessListener<any>;
    };
    constructor(worker: Worker, params: IPCParams<T>);
    protected onMessage(message: IMasterMessage): void;
    send(message: IWorkerMessage): void;
    subscribe(channel: string, listner: ProcessListener<any>): void;
    unsubscribe(channel: string): void;
    publish(channel: string, data: any): void;
    close(): void;
}