Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for IsConnectionOpen (0.24 sec)

  1. 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)
Back to top