Method Close

client/queueprotocol.go:103–105

Close close client

()

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

// NewMessage new message
func (q *QueueProtocol) NewMessage(topic string, msgid int64, data interface{}) *queue.Message {