Versions in this module Expand all Collapse all v1 v1.1.21 Jul 5, 2021 Changes in this version + type Client struct + func (_m *Client) Close() + func (_m *Client) CloseQueue() (*types.Reply, error) + func (_m *Client) FreeMessage(msg ...*queue.Message) + func (_m *Client) GetConfig() *types.TuringchainConfig + func (_m *Client) NewMessage(topic string, ty int64, data interface{}) *queue.Message + func (_m *Client) Recv() chan *queue.Message + func (_m *Client) Reply(msg *queue.Message) + func (_m *Client) Send(msg *queue.Message, waitReply bool) error + func (_m *Client) SendTimeout(msg *queue.Message, waitReply bool, timeout time.Duration) error + func (_m *Client) Sub(topic string) + func (_m *Client) Wait(msg *queue.Message) (*queue.Message, error) + func (_m *Client) WaitTimeout(msg *queue.Message, timeout time.Duration) (*queue.Message, error)
Go to main page