Method Notify

client/queueprotocol.go:98–100

Notify new and send client message

(topic string, ty int64, data interface{})

// Notify new and send client message
func (q *QueueProtocol) Notify(topic string, ty int64, data interface{}) (*queue.Message, error) {
	return q.notify(topic, ty, data)
}

// Close close client
func (q *QueueProtocol) Close() {