Class CompleteService

new CompleteService(
    messageRepository: MessageRepository,
    analyzeQueue: AnalyzeQueue,
): CompleteService

createMessage(
    data: {
        analyze: string | null;
        campaignId: string;
        connection: HttpConnection;
        errors: HttpError[];
        finishTime: number;
        messageId: string;
        method: "HEAD" | "GET" | "POST" | "PUT" | "PATCH" | "DELETE" | "OPTIONS";
        payload: HttpPayload;
        proxyId: string;
        requestBody: HttpBody;
        requestHeaders: HttpHeaders;
        responseBody: HttpBody;
        responseHeaders: HttpHeaders;
        sessionId: string;
        startTime: number;
        status: number;
        targetId: string;
        type:
            | "websocket"
            | "normal-simple"
            | "normal-stream-request"
            | "normal-stream-response";
        url: string;
    },
): Promise<void>

register(container: DIContainer): void