BaseTask.java 文件源码

void sendResponse(GeneratedMessage message) {
    Protocol.ServerResponse.Builder response = Protocol.ServerResponse.newBuilder();
    response.setRequestId(requestId);

    if(message instanceof Protocol.ListTasksResponse) {
        response.setListResponse((Protocol.ListTasksResponse) message);
    }

    if(message instanceof Protocol.SubmitTaskResponse) {
        response.setSubmitResponse((Protocol.SubmitTaskResponse) message);
    }

    if(message instanceof Protocol.SubscribeResponse) {
        response.setSubscribeResponse((Protocol.SubscribeResponse) message);
    }

    Protocol.ServerResponse answer = response.build();

    try {
        OutputStream outputStream = socket.getOutputStream();
        outputStream.write(answer.getSerializedSize());
        answer.writeTo(outputStream);
    } catch (IOException e) {
        e.printStackTrace();
    }
}