import { ClusterMessaging } from "../net/cluster-messaging"; import { ClusterInfo, NodeId } from "../net/cluster-state"; import { ActorDirectory } from "./actor-directory"; import { ActorExecution } from "./actor-execution"; import { ActorPlacement } from "./actor-placement"; import { ActorId, ActorRequestType, ActorType } from "./actor-types"; declare class ActorMessaging { private clusterInfo; private clusterMessaging; private actorPlacement; private actorDirectory; private actorExecution; private config; private messageCounter; private messagesInFlight; constructor(clusterInfo: ClusterInfo, clusterMessaging: ClusterMessaging, actorPlacement: ActorPlacement, actorDirectory: ActorDirectory, actorExecution: ActorExecution, config: any); sendActorRequest(actorType: ActorType, actorId: ActorId, contents: any, oneWay?: boolean, requestType?: ActorRequestType, respondTo?: NodeId): Promise; updatePendingMessages(): Promise; private sendNormalResponse(originalMessage, response); private sendErrorResponse(originalMessage, response); private handleActorRequest(message); private onActorRequestMessage(message); private onActorResponseMessage(message); private onActorErrorMessage(message); private onMessage(message, headers); } export default ActorMessaging; export { ActorMessaging };