From c707bdc25d3e5d9e96d37ddc8eb0fb5e1e7d5821 Mon Sep 17 00:00:00 2001
From: guzeng <gz@flyrise.cn>
Date: Fri, 18 Jun 2021 15:44:49 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=8F=91=E9=80=81=E5=BB=B6?=
 =?UTF-8?q?=E8=BF=9F=E6=B6=88=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 rabbitmq.pb.go | 4 ++++
 rabbitmq.proto | 1 +
 2 files changed, 5 insertions(+)

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