Method QueueSubscribe

core/services/messaging/interfaces.go:21–21

(subject, queue string, handler func([]byte))

	Publisher
	Subscribe(subject string, handler func([]byte)) (Subscription, error)
	QueueSubscribe(subject, queue string, handler func([]byte)) (Subscription, error)
	QueueSubscribeReply(subject, queue string, handler func(data []byte, reply func([]byte))) (Subscription, error)
	SubscribeReply(subject string, handler func(data []byte, reply func([]byte))) (Subscription, error)
	Request(subject string, data []byte, timeout time.Duration) ([]byte, error)