Documentation
¶
Index ¶
- type MultiClient
- func (this *MultiClient) AddRoute(topic string, callback paho.MessageHandler)
- func (this *MultiClient) Connect() paho.Token
- func (this *MultiClient) Disconnect(quiesce uint)
- func (this *MultiClient) IsConnected() bool
- func (this *MultiClient) IsConnectionOpen() bool
- func (this *MultiClient) OptionsReader() paho.ClientOptionsReader
- func (this *MultiClient) Publish(topic string, qos byte, retained bool, payload interface{}) paho.Token
- func (this *MultiClient) Subscribe(topic string, qos byte, callback paho.MessageHandler) paho.Token
- func (this *MultiClient) SubscribeMultiple(filters map[string]byte, callback paho.MessageHandler) paho.Token
- func (this *MultiClient) Unsubscribe(topics ...string) paho.Token
- type Token
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MultiClient ¶
type MultiClient struct {
// contains filtered or unexported fields
}
func NewClient ¶
func NewClient(configs []configuration.MqttConfig, setOptions func(*paho.ClientOptions)) *MultiClient
func (*MultiClient) AddRoute ¶
func (this *MultiClient) AddRoute(topic string, callback paho.MessageHandler)
func (*MultiClient) Connect ¶
func (this *MultiClient) Connect() paho.Token
func (*MultiClient) Disconnect ¶
func (this *MultiClient) Disconnect(quiesce uint)
func (*MultiClient) IsConnected ¶
func (this *MultiClient) IsConnected() bool
func (*MultiClient) IsConnectionOpen ¶
func (this *MultiClient) IsConnectionOpen() bool
func (*MultiClient) OptionsReader ¶
func (this *MultiClient) OptionsReader() paho.ClientOptionsReader
func (*MultiClient) Subscribe ¶
func (this *MultiClient) Subscribe(topic string, qos byte, callback paho.MessageHandler) paho.Token
func (*MultiClient) SubscribeMultiple ¶
func (this *MultiClient) SubscribeMultiple(filters map[string]byte, callback paho.MessageHandler) paho.Token
func (*MultiClient) Unsubscribe ¶
func (this *MultiClient) Unsubscribe(topics ...string) paho.Token
Source Files
Click to show internal directories.
Click to hide internal directories.