ywt-platform-outpatient-parent/ywt-platform-outpatient-base/target/classes/mq.proto

syntax = "proto3";

package com.ywt.gapi.mq;

option java_multiple_files = true;
option java_outer_classname = "MqProto";
option java_package = "com.ywt.gapi.mq";

//gRPC消息队列请求消息体
message ExecuteGRPCRequest {
    string method = 1; //gRPC方法名(/${package}.${service}/${method})，如：/com.ywt.gapi.mq.MQExecutorService/executeGRPC
    bytes data = 2; //gRPC方法的参数(byte序列化)
    int32 priority = 3; //优先级(暂时保留设计)
    string msgId = 4; //消息ID，不需传入(仅为了消息完整性而定义)
}

//gRPC请求消息体入队返回结果
message ExecuteGRPCResponse {
    int32 code = 1; //返回码(0：成功, 1：失败)
    string msgId = 2; //消息ID
}

//基于消息队列的导步执行器
service MQExecutorService {
    rpc executeGRPC (ExecuteGRPCRequest) returns (ExecuteGRPCResponse); //异步执行gRPC请求
}