mqtt

README

MQTT

MQTT is an Internet of Things connectivity protocol featuring a lightweight publish/subscribe messaging transport. It is useful for it's small code footprint and minimal network bandwidth usage.

For more info about the MQTT machine to machine message broker click here.

How to Install

Install running:

go get github.com/hybridgroup/gobot && go install github.com/hybridgroup/gobot/platforms/mqtt

How to Use

Before running the example, make sure you have an MQTT message broker running somewhere you can connect to

package main

import (
  "github.com/hybridgroup/gobot"
  "github.com/hybridgroup/gobot/platforms/mqtt"
  "fmt"
  "time"
)

func main() {
  gbot := gobot.NewGobot()

  mqttAdaptor := mqtt.NewMqttAdaptor("server", "tcp://0.0.0.0:1883", "pinger")

  work := func() {
    mqttAdaptor.On("hello", func(data []byte) {
      fmt.Println("hello")
    })
    mqttAdaptor.On("hola", func(data []byte) {
      fmt.Println("hola")
    })
    data := []byte("o")
    gobot.Every(1*time.Second, func() {
      mqttAdaptor.Publish("hello", data)
    })
    gobot.Every(5*time.Second, func() {
      mqttAdaptor.Publish("hola", data)
    })
  }

  robot := gobot.NewRobot("mqttBot",
    []gobot.Connection{mqttAdaptor},
    work,
  )

  gbot.AddRobot(robot)

  gbot.Start()
}

Supported Features

• Publish messages
• Respond to incoming message events

Contributing

• All patches must be provided under the Apache 2.0 License
• Please use the -s option in git to "sign off" that the commit is your work and you are providing it under the Apache 2.0 License
• Submit a Github Pull Request to the appropriate branch and ideally discuss the changes with us in IRC.
• We will look at the patch, test it out, and give you feedback.
• Avoid doing minor whitespace changes, renamings, etc. along with merged content. These will be done by the maintainers from time to time but they can complicate merges and should be done seperately.
• Take care to maintain the existing coding style.
• Add unit tests for any new or changed functionality
• All pull requests should be "fast forward"
• If there are commits after yours use “git rebase -i <new_head_branch>”
• If you have local changes you may need to use “git stash”
• For git help see progit which is an awesome (and free) book on git

License

Copyright (c) 2013-2014 The Hybrid Group. Licensed under the Apache 2.0 license.

Documentation

Overview

Package mqtt provides Gobot adaptor for the mqtt message service.

Installing:

go get github.com/hybridgroup/gobot/platforms/mqtt

For further information refer to mqtt README: https://github.com/hybridgroup/gobot/blob/master/platforms/mqtt/README.md

Index

• type MqttAdaptor
  • func NewMqttAdaptor(name string, host string, clientID string) *MqttAdaptor
  • func (a *MqttAdaptor) Connect() (errs []error)
  • func (a *MqttAdaptor) Disconnect() (err error)
  • func (a *MqttAdaptor) Finalize() (errs []error)
  • func (a *MqttAdaptor) Name() string
  • func (a *MqttAdaptor) On(event string, f func(s []byte)) bool
  • func (a *MqttAdaptor) Publish(topic string, message []byte) bool

Types

type MqttAdaptor

type MqttAdaptor struct {
	Host string
	// contains filtered or unexported fields
}

func NewMqttAdaptor

func NewMqttAdaptor(name string, host string, clientID string) *MqttAdaptor

NewMqttAdaptor creates a new mqtt adaptor with specified name, host and client id

func (*MqttAdaptor) Connect

func (a *MqttAdaptor) Connect() (errs []error)

Connect returns true if connection to mqtt is established

func (*MqttAdaptor) Disconnect

func (a *MqttAdaptor) Disconnect() (err error)

Disconnect returns true if connection to mqtt is closed

func (*MqttAdaptor) Finalize

func (a *MqttAdaptor) Finalize() (errs []error)

Finalize returns true if connection to mqtt is finalized succesfully

func (*MqttAdaptor) Name

func (a *MqttAdaptor) Name() string

func (*MqttAdaptor) On

func (a *MqttAdaptor) On(event string, f func(s []byte)) bool

Subscribe to a topic, and then call the message handler function when data is received

func (*MqttAdaptor) Publish

func (a *MqttAdaptor) Publish(topic string, message []byte) bool

Publish a message under a specific topic