import * as m3o from '@m3o/m3o-node';
export declare class MqService {
    private client;
    constructor(token: string);
    publish(request: PublishRequest): Promise<PublishResponse>;
    subscribe(request: SubscribeRequest): Promise<m3o.Stream<SubscribeRequest, SubscribeResponse>>;
}
export interface PublishRequest {
    message?: {
        [key: string]: any;
    };
    topic?: string;
}
export interface PublishResponse {
}
export interface SubscribeRequest {
    topic?: string;
}
export interface SubscribeResponse {
    message?: {
        [key: string]: any;
    };
    topic?: string;
}