Documentation ¶
Index ¶
Constants ¶
View Source
const ( Scheme = "mqtt-v3" PropertiesPrefix = "camel.component." + Scheme AttributeMqttMessageID = "camel.apache.org/mqtt.message.id" AttributeMqttMessageRetained = "camel.apache.org/mqtt.message.retained" AttributeMqttMessageDuplicate = "camel.apache.org/mqtt.message.duplicate" AttributeMqttMessageQUOS = "camel.apache.org/mqtt.message.qus" )
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Component ¶
type Component struct {
components.DefaultComponent
}
type Consumer ¶
type Consumer struct { components.DefaultConsumer // contains filtered or unexported fields }
type Endpoint ¶
type Endpoint struct { components.DefaultEndpoint // contains filtered or unexported fields }
type OptionFn ¶
type OptionFn func(*mqtt.ClientOptions)
type Producer ¶
type Producer struct { components.DefaultProducer // contains filtered or unexported fields }
Click to show internal directories.
Click to hide internal directories.