增加发送延迟消息

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) {

rabbitmq.proto

@@ -19,4 +19,5 @@ message Response {
 // rpc方法
 service RabbitmqService {
     rpc send (Request) returns (Response);    // 发送消息
+    rpc sendDelay (Request) returns (Response);    // 发送延迟消息
 }