// NewSubscriber returns a new MQTT message subscriber.
NewSubscriber returns a new MQTT message subscriber.
// NewSubscriber returns a new MQTT message subscriber .
func NewSubscriber(address string, timeout time.Duration, logger log.Logger) (messaging.Subscriber, error) {
	ret := subscriber{
		address:       address,
		timeout:       timeout,
		logger:        logger,
		subscriptions: make(map[string]subscription),
	}
	return ret, nil
}
func NewSubscriber ( address string , timeout time . Duration , logger log . Logger ) ( messaging . Subscriber , error ) { ret := subscriber { address : address , timeout : timeout , logger : logger , subscriptions : make ( map [ string ] subscription ) , } return ret , nil }
NewSubscriber returns a new MQTT message subscriber.
NewSubscriber returns a new MQTT message subscriber .