No description or website provided.
Clone or download
Permalink
Failed to load latest commit information.
cmd Remove extraneous var Dec 8, 2017
fvt API updates in preparation for 1.0 release Mar 23, 2015
packets Return error if unable to read the expected size of data Sep 8, 2017
.gitignore fix some things Jan 27, 2014
CONTRIBUTING.md Update references for new hosting on github Feb 10, 2016
DISTRIBUTION Initial contribution Jan 7, 2014
LICENSE Initial contribution Jan 7, 2014
README.md Add GoDoc and Go Report Card badges Jan 9, 2018
about.html add required legal files Mar 5, 2014
client.go Only cleanup messageids if cleansession is set Nov 2, 2018
components.go Bring packet library internal an fix golint reported issues Dec 30, 2014
edl-v10 add required legal files Mar 5, 2014
epl-v10 add required legal files Mar 5, 2014
filestore.go Order the filestore files when resuming by modified time Nov 1, 2018
fvt_client_test.go Fix data race in reconnect Oct 25, 2018
fvt_store_test.go Fix the test for deleting msg from memory store Dec 8, 2017
fvt_test.go Make FVTAddr configurable by using env variable. Apr 3, 2016
memstore.go fix: store.messages not del in map Nov 16, 2017
message.go Merge pull request #214 from TheSilentForest/manually_ack_messages Oct 25, 2018
messageids.go Implements store resume Mar 15, 2018
net.go Support ConnectTimeout on websocket connections Oct 30, 2018
notice.html add required legal files Mar 5, 2014
oops.go Remove potential panics with unhelpful messages Jun 30, 2016
options.go Make the tlsConfig a pointer Oct 25, 2018
options_reader.go Make the tlsConfig a pointer Oct 25, 2018
ping.go Use atomic ints to set the time for lastSent and lastReceived, and pi… Aug 17, 2017
router.go Ack Qos1/2 messages after the handler has returned Oct 30, 2018
store.go Implements store resume Mar 15, 2018
token.go Add SessionPresent() to ConnectToken Oct 25, 2018
token_test.go Error all outstanding tokens at disconnection Jan 5, 2018
topic.go Follow lint suggestions Mar 29, 2017
trace.go Add no-op logging capability Jan 10, 2018
unit_client_test.go Add is connection open method to interface May 18, 2018
unit_message_test.go Add ability to use per broker credentials Jul 11, 2018
unit_messageids_test.go Merge branch 'master' into master Sep 8, 2017
unit_options_test.go Use atomic ints to set the time for lastSent and lastReceived, and pi… Aug 17, 2017
unit_ping_test.go Update references for new hosting on github Feb 10, 2016
unit_router_test.go Fix test with new ackFunc stuff Oct 30, 2018
unit_store_test.go Remove potential panics with unhelpful messages Jun 30, 2016
unit_topic_test.go API updates in preparation for 1.0 release Mar 23, 2015

README.md

GoDoc Go Report Card

Eclipse Paho MQTT Go client

This repository contains the source code for the Eclipse Paho MQTT Go client library.

This code builds a library which enable applications to connect to an MQTT broker to publish messages, and to subscribe to topics and receive published messages.

This library supports a fully asynchronous mode of operation.

Installation and Build

This client is designed to work with the standard Go tools, so installation is as easy as:

go get github.com/eclipse/paho.mqtt.golang

The client depends on Google's websockets and proxy package, also easily installed with the commands:

go get golang.org/x/net/websocket
go get golang.org/x/net/proxy

Usage and API

Detailed API documentation is available by using to godoc tool, or can be browsed online using the godoc.org service.

Make use of the library by importing it in your Go client source code. For example,

import "github.com/eclipse/paho.mqtt.golang"

Samples are available in the cmd directory for reference.

Runtime tracing

Tracing is enabled by assigning logs (from the Go log package) to the logging endpoints, ERROR, CRITICAL, WARN and DEBUG

Reporting bugs

Please report bugs by raising issues for this project in github https://github.com/eclipse/paho.mqtt.golang/issues

More information

Discussion of the Paho clients takes place on the Eclipse paho-dev mailing list.

General questions about the MQTT protocol are discussed in the MQTT Google Group.

There is much more information available via the MQTT community site.