mqtt_consumer

Documentation

Index

• type MQTTConsumer
  • func NewMQTTConsumer(opts *options.ConsumerOptions) (*MQTTConsumer, error)
  • func (c *MQTTConsumer) Start(ctx context.Context, msgHandler func(msg []byte), ...) error

Types

type MQTTConsumer

type MQTTConsumer struct {
	// contains filtered or unexported fields
}

func NewMQTTConsumer

func NewMQTTConsumer(opts *options.ConsumerOptions) (*MQTTConsumer, error)

func (*MQTTConsumer) Start

func (c *MQTTConsumer) Start(ctx context.Context, msgHandler func(msg []byte), properties map[string]interface{}) error