mqtt

type Consumer interface {
	Start(chan bool)
}

type Mqtt5Consumer struct {
	Id         int
	Connection *autopaho.ConnectionManager
	Topic      string
	Config     config.Config
	// contains filtered or unexported fields
}

type Mqtt5Publisher struct {
	Id         int
	Connection *autopaho.ConnectionManager
	Topic      string
	Config     config.Config
	// contains filtered or unexported fields
}

type MqttConsumer struct {
	Id         int
	Connection mqtt.Client
	Topic      string
	Config     config.Config
	// contains filtered or unexported fields
}

type MqttPublisher struct {
	Id         int
	Connection mqtt.Client
	Topic      string
	Config     config.Config
	// contains filtered or unexported fields
}

type Publisher interface {
	Start(chan bool, chan bool)
}