fimpmqtt

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

type ConnectorConfig struct {
	MqttServerURI         string
	MqttUsername          string
	MqttPassword          string
	MqttTopicGlobalPrefix string
	MqttClientIdPrefix    string
}

type Message struct {
	AddressStr string
	Address    fimpgo.Address
	Payload    fimpgo.FimpMessage
	RawPayload []byte
	Header     map[string]string
	CancelOp   bool // if true , listening end should close all operations
}

type MsgPipeline chan Message