- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for IsConnectionOpen (0.24 sec)
-
internal/event/target/mqtt.go
if err := target.init(); err != nil { return false, err } return target.isActive() } func (target *MQTTTarget) isActive() (bool, error) { if !target.client.IsConnectionOpen() { return false, store.ErrNotConnected } return true, nil } // send - sends an event to the mqtt. func (target *MQTTTarget) send(eventData event.Event) error {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 8.2K bytes - Viewed (0)