diff --git a/rabbitmq.pb.go b/rabbitmq.pb.go index c352137..696a3b6 100644 --- a/rabbitmq.pb.go +++ b/rabbitmq.pb.go @@ -99,6 +99,7 @@ func init() { type RabbitmqService interface { Send(in *Request, out *Response) error + SendDelay(in *Request, out *Response) error } // AcceptRabbitmqServiceClient accepts connections on the listener and serves requests @@ -173,6 +174,9 @@ func NewRabbitmqServiceClient(conn io.ReadWriteCloser) (*RabbitmqServiceClient, func (c *RabbitmqServiceClient) Send(in *Request, out *Response) error { return c.Call("RabbitmqService.Send", in, out) } +func (c *RabbitmqServiceClient) SendDelay(in *Request, out *Response) error { + return c.Call("RabbitmqService.SendDelay", in, out) +} // DialRabbitmqService connects to an RabbitmqService at the specified network address. func DialRabbitmqService(network, addr string) (*RabbitmqServiceClient, *rpc.Client, error) { diff --git a/rabbitmq.proto b/rabbitmq.proto index dadc26f..b264a04 100644 --- a/rabbitmq.proto +++ b/rabbitmq.proto @@ -19,4 +19,5 @@ message Response { // rpc方法 service RabbitmqService { rpc send (Request) returns (Response); // 发送消息 + rpc sendDelay (Request) returns (Response); // 发送延迟消息 } \ No newline at end of file