rpcqueue

Documentation

Index

• type RPCQueue
  • func NewRPCQueue(ctx context.Context, conn *amqp.Connection, exchangeName, reqQueueName string, ...) (rq *RPCQueue, err error)
  • func (rq *RPCQueue) ConsumeReplyRoutine(msgs <-chan amqp.Delivery)
  • func (rq *RPCQueue) SendRequest(corrID string, queueNamereqBody interface{}) (string, error)

Types

type RPCQueue

type RPCQueue struct {
	// contains filtered or unexported fields
}

RPCQueue is the class for all the RPCs

func NewRPCQueue

func NewRPCQueue(ctx context.Context, conn *amqp.Connection, exchangeName, reqQueueName string, timeout time.Duration) (rq *RPCQueue, err error)

NewRPCQueue creates a new RPC Queue

func (*RPCQueue) ConsumeReplyRoutine

func (rq *RPCQueue) ConsumeReplyRoutine(msgs <-chan amqp.Delivery)

ConsumeReplyRoutine 消费响应

func (*RPCQueue) SendRequest

func (rq *RPCQueue) SendRequest(corrID string, queueNamereqBody interface{}) (string, error)

SendRequest 发送请求，并且监听等待响应。请求和响应都是JSON序列化的对象。