import { Logger } from '@alterior/logging';
import * as ioredis from 'ioredis';
export interface AppEvent<T = any> {
    name: string;
    data: T;
}
export declare class InterServerCommunications<T> {
    private logger;
    private redis;
    constructor(logger: Logger, redis: ioredis.Redis | ioredis.Cluster);
    disconnect(): void;
    private connected;
    connect(): void;
    subscriber: ioredis.Redis | ioredis.Cluster;
    private _messages;
    readonly messages: import("rxjs").Observable<T>;
    send(message: any): Promise<string>;
}