Documentation ¶
Index ¶
- type Client
- func (_m *Client) Close()
- func (_m *Client) CloseQueue() (*types.Reply, error)
- func (_m *Client) NewMessage(topic string, ty int64, data interface{}) queue.Message
- func (_m *Client) Recv() chan 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
Client is an autogenerated mock type for the Client type
func (*Client) CloseQueue ¶
CloseQueue provides a mock function with given fields:
func (*Client) NewMessage ¶
NewMessage provides a mock function with given fields: topic, ty, data
func (*Client) SendTimeout ¶
SendTimeout provides a mock function with given fields: msg, waitReply, timeout
Click to show internal directories.
Click to hide internal directories.