eclipse / paho.mqtt.golang Goto Github PK

normal

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

go get github.com/gorilla/websocket
go get golang.org/x/net/proxy

t := client.Publish("topic", qos, retained, msg)
go func() {
    _ = t.Wait() // Can also use '<-t.Done()' in releases > 1.2.0
    if t.Error() != nil {
        log.Error(t.Error()) // Use your preferred logging technique (or just fmt.Printf)
    }
}()
func main() {
	mqtt.ERROR = log.New(os.Stdout, "[ERROR] ", 0)
	mqtt.CRITICAL = log.New(os.Stdout, "[CRIT] ", 0)
	mqtt.WARN = log.New(os.Stdout, "[WARN]  ", 0)
	mqtt.DEBUG = log.New(os.Stdout, "[DEBUG] ", 0)

	// Connect, Subscribe, Publish etc..
}
1d65364
efdb79c
  case _, ok := <-c.stop:

          if ok {

                  close(c.stop)

          }

  case <-c.stop:

  default:

          close(c.stop)
}
//Wait for all workers to finish before closing connection
c.workers.Wait()

eval go get -t -v ./...

github.com/mainflux/mainflux/vendor/github.com/eclipse/paho.mqtt.golang/samples
# github.com/mainflux/mainflux/vendor/github.com/eclipse/paho.mqtt.golang/samples
vendor/github.com/eclipse/paho.mqtt.golang/samples/routing.go:61: main redeclared in this block
    previous declaration at vendor/github.com/eclipse/paho.mqtt.golang/samples/custom_store.go:65
vendor/github.com/eclipse/paho.mqtt.golang/samples/sample.go:42: main redeclared in this block
    previous declaration at vendor/github.com/eclipse/paho.mqtt.golang/samples/routing.go:61
vendor/github.com/eclipse/paho.mqtt.golang/samples/sample.go:107: main.func1 redeclared in this block
    previous declaration at vendor/github.com/eclipse/paho.mqtt.golang/samples/custom_store.go:73
vendor/github.com/eclipse/paho.mqtt.golang/samples/simple.go:31: main redeclared in this block
    previous declaration at vendor/github.com/eclipse/paho.mqtt.golang/samples/sample.go:42
vendor/github.com/eclipse/paho.mqtt.golang/samples/ssl.go:97: f redeclared in this block
    previous declaration at vendor/github.com/eclipse/paho.mqtt.golang/samples/simple.go:29
vendor/github.com/eclipse/paho.mqtt.golang/samples/ssl.go:99: main redeclared in this block
    previous declaration at vendor/github.com/eclipse/paho.mqtt.golang/samples/simple.go:31
vendor/github.com/eclipse/paho.mqtt.golang/samples/stdinpub.go:31: main redeclared in this block
    previous declaration at vendor/github.com/eclipse/paho.mqtt.golang/samples/ssl.go:99
vendor/github.com/eclipse/paho.mqtt.golang/samples/stdoutsub.go:37: main redeclared in this block
    previous declaration at vendor/github.com/eclipse/paho.mqtt.golang/samples/stdinpub.go:31
vendor/github.com/eclipse/paho.mqtt.golang/samples/stdoutsub.go:43: main.func1 redeclared in this block
    previous declaration at vendor/github.com/eclipse/paho.mqtt.golang/samples/sample.go:107

func (c *client) disconnect() {
    c.closeStop()
    if c.conn != nil {
        c.conn.Close()
    }
    c.workers.Wait()
    close(c.stopRouter)
    DEBUG.Println(CLI, "disconnected")
    c.persist.Close()
}

mosquitto version 1.4.8 (build date Sun, 14 Feb 2016 15:06:55 +0000)
go version go1.7 linux/amd64

package main

import (
    "log"
    "os"
    MQTT "github.com/eclipse/paho.mqtt.golang"
)

func main() {
    MQTT.ERROR = log.New(os.Stdout, "", 0)
    MQTT.WARN = log.New(os.Stdout, "", 0)
    MQTT.DEBUG = log.New(os.Stdout, "", 0)

    quit := make(chan struct{})

    connOpts := MQTT.NewClientOptions()
    connOpts.AddBroker("tcp://127.0.0.1:1883")
    connOpts.SetAutoReconnect(true)
    connOpts.SetCleanSession(true)
    connOpts.SetConnectionLostHandler(func(client MQTT.Client, err error) {
        close(quit)
    })
    client := MQTT.NewClient(connOpts)
    if token := client.Connect(); token.Wait() && token.Error() != nil {
        log.Println("connect", token.Error())
        return
    }
    log.Println("Stop mosquitto now, please.")
    select {
    case <-quit:
        log.Println("quit")
    }
    if client.IsConnected() {
        log.Println("disconnecting")
        client.Disconnect(5000)
    }
    log.Println("exit")
}

package main

import (
    "fmt"
    "log"
    "os"
    "time"

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

func main() {
    mqtt.DEBUG = log.New(os.Stdout, "", 0)
    mqtt.ERROR = log.New(os.Stdout, "", 0)

    // Set some broker that is not reachable
    opts := mqtt.NewClientOptions().AddBroker("tcp://notreachable:1883").SetClientID("gotrivial")

    c := mqtt.NewClient(opts)

    // Connect should and will fail
    if token := c.Connect(); token.Wait() && token.Error() != nil {
        fmt.Println(token.Error())
    }

    // Check if client is connected and if yes, send message
    if (c.IsConnected()) {

        // SHOULD NOT GO HERE, BUT DOES
        fmt.Println("publishing message")
        token := c.Publish("testtopic", 0, false, "testmessage")

        // WILL NEVER GO HERE IF BROKER IS NOT REACHABLE
        fmt.Println("waiting for publish to complete")
        token.WaitTimeout(time.Second*5)
        fmt.Println("publish finished")
    }

    fmt.Println("Disconnecting")
    c.Disconnect(250)

    time.Sleep(1 * time.Second)
}
func start_mqtt() {
opts := MQTTT.NewClientOptions().AddBroker(MQTT)
    opts.SetClientID("MY_CLIENT_1")
    opts.SetAutoReconnect(true)
    opts.SetKeepAlive(time.Second * 300)
    opts.SetDefaultPublishHandler(f)

    MqttClient = MQTTT.NewClient(opts)

    if token := MqttClient.Connect(); token.Wait() && token.Error() != nil {
        log.Println("Error while connecting to Mqtt Broker.")
        panic(token.Error())
    }
    log.Println("Mqtt connection successful.")

    if token := MqttClient.Subscribe("MY_CLIENT_1", 1, nil); token.Wait() && token.Error() != nil {
        log.Println("Error while subscribing to tpoic 1.")
        fmt.Println(token.Error())
        os.Exit(1)
    }
    log.Println("Topic subscription successful.")

//UNTIL HERE IT WORKS 

    for i := 0; i < 5; i++ {
    text := fmt.Sprintf("this is msg #%d!", i)
    token := MqttClient.Publish("MY_CLIENT_2", 1, false, text)
    token.Wait()
    }

//PUBLISH IS NOT WORKING 

}

1d65364
    opts := mqtt.NewClientOptions()
    opts.AddBroker(secureMQTTHost)
    opts.SetCleanSession(false)
    opts.SetAutoReconnect(true)
    opts.SetUsername(username)
    opts.SetPassword(password)
    if config.DebugMode {
        mqtt.DEBUG = log.New(os.Stdout, "DEBUG ", 0)
        mqtt.WARN = log.New(os.Stdout, "WARN ", 0)
        mqtt.CRITICAL = log.New(os.Stdout, "CRITICAL ", 0)
        mqtt.ERROR = log.New(os.Stdout, "ERROR ", 0)
    }

    mqttClient =: mqtt.NewClient(opts)
    if token := s.mqttClient.Connect(); token.Wait() && token.Error() != nil {
        log.Fatalf("Could not connect to mqtt broker.")
    }
DEBUG [client]   Connect()
DEBUG [store]    memorystore initialized
DEBUG [client]   about to write new connect msg
DEBUG [client]   socket connected to broker
DEBUG [client]   Using MQTT 3.1.1 protocol
DEBUG [net]      connect started
DEBUG [net]      received connack
DEBUG [client]   client is connected
DEBUG [client]   exit startClient
DEBUG [net]      outgoing started
DEBUG [net]      outgoing waiting for an outbound message
DEBUG [net]      incoming started
DEBUG [pinger]   keepalive starting
DEBUG [net]      logic started
DEBUG [net]      logic waiting for msg on ibound
DEBUG [client]   enter Publish
DEBUG [client]   sending publish message, topic: heartbeat
DEBUG [net]      obound wrote msg, id: 1
DEBUG [net]      outgoing waiting for an outbound message
DEBUG [net]      Received Message
DEBUG [net]      logic got msg on ibound
DEBUG [store]    memorystore del: message 1 was deleted
DEBUG [net]      received puback, id: 1
DEBUG [net]      logic waiting for msg on ibound
...
ERROR [net]      incoming stopped with error EOF
ERROR [net]      logic received from error channel, other components have errored, stopping
DEBUG [pinger]   keepalive stopped
DEBUG [net]      outgoing stopped
DEBUG [client]   enter reconnect
DEBUG [client]   about to write new connect msg
DEBUG Connection lost: EOF
DEBUG [client]   socket connected to broker
DEBUG [client]   Using MQTT 3.1.1 protocol
DEBUG [net]      connect started

  close(c.stop)

  select {

  case _, ok := <-c.stop:

          if ok {

                  close(c.stop)

          }

  }

15034ff
d7795b6
ccf6fcf
ccf6fcf
546c47a
546c47a
SHA
33499ed
	c.msgRouter, c.stopRouter = newRouter()
	c.msgRouter.setDefaultHandler(c.options.DefaultPublishHander)
	if !c.options.AutoReconnect {
		c.options.MessageChannelDepth = 0
	}

c.subscribled[string] = qos  // it should be mutexed.

18fcc52
func CreateMQTTClient(clientID string) (client MQTT.Client) {
    username := viper.GetString("messaging.rabbitmq.username")
    password := viper.GetString("messaging.rabbitmq.password")
    host := viper.GetString("messaging.rabbitmq.host")
    mqqtPort := viper.GetString("messaging.rabbitmq.mqqtPort")
    rabbitMqMQQTURL := "tcp://" + host + ":" + mqqtPort
    opts := MQTT.NewClientOptions().AddBroker(rabbitMqMQQTURL)
    opts.SetClientID(clientID)
    opts.Username = username
    opts.Password = password
    opts.SetCleanSession(false)
    opts.ProtocolVersion=4
    opts.OnConnect=OnConnectHandler
    opts.AutoReconnect = true
    opts.OnConnectionLost = OnConnectionLostHandler
    cli := MQTT.NewClient(opts)

    log.Println(cli.IsConnected())

    token := cli.Connect()
    token.Wait()
    if token.Error() != nil {
        log.Print(token.Error())
    }

    return cli

}

ratatosk ➜  ~  go version
go version go1.3.3 linux/arm

url := fmt.Sprintf("tcp://%s:%d", host, port)
    opts := MQTT.NewClientOptions().AddBroker(url)
    opts.SetDefaultPublishHandler(OnMessage)
    opts.SetConnectionLostHandler(ConnectionLost)

    logger.Debug("Connecting to ", url)
    c := MQTT.NewClient(opts)
    if token := c.Connect(); token.Wait() && token.Error() != nil {
        panic(token.Error())
    }
    logger.Debug("Subscribing to ", topic)
    //subscribe to the topic /go-mqtt/sample and request messages to be delivered
    //at a maximum qos of zero, wait for the receipt to confirm the subscription
    if token := c.Subscribe(topic, 2, nil); token.Wait() && token.Error() != nil {
        fmt.Println(token.Error())
        os.Exit(1)
    }
[net]      Received Message
[net]      logic got msg on ibound
[net]      received pubrel, id: 33
[net]      logic waiting for msg on ibound
[net]      obound priority msg to write, type *packets.PubcompPacket
[net]      outgoing waiting for an outbound message
13:58:49.209 UpdateLastUp ▶ DEBUG  Updating last update for  fenrir : 28-0014550
75dff : 2016-02-24 13:58:49.110356 +0000 UTC
[pinger]   keepalive sending ping
[net]      Received Message
[net]      logic got msg on ibound
[net]      received pingresp
[net]      logic waiting for msg on ibound
[net]      outgoing stopped
[net]      incoming stopped
13:59:29.146 ConnectionLo ▶ ERROR  Connection Lost: pingresp not received, disconnecting
[client]   enter reconnect
[client]   about to write new connect msg
[client]   socket connected to broker
[client]   Using MQTT 3.1.1 protocol
[net]      connect started
[net]      received connack
[client]   client is reconnected
[net]      outgoing started
[net]      outgoing waiting for an outbound message
[net]      logic started
[net]      logic waiting for msg on ibound
[pinger]   keepalive starting
[pinger]   keepalive sending ping
[net]      incoming started
[net]      Received Message
[net]      logic got msg on ibound
[net]      received pingresp
[net]      logic waiting for msg on ibound
[pinger]   keepalive sending ping
[net]      Received Message
[net]      logic got msg on ibound
[net]      received pingresp
[net]      logic waiting for msg on ibound
[pinger]   keepalive sending ping
[net]      outgoing stopped
[net]      incoming stopped
13:59:49.158 ConnectionLo ▶ ERROR  Connection Lost: pingresp not received, disconnecting
[client]   enter reconnect
[client]   about to write new connect msg
[client]   socket connected to broker
[client]   Using MQTT 3.1.1 protocol
[net]      connect started
[net]      received connack
[client]   client is reconnected
[net]      outgoing started
[net]      outgoing waiting for an outbound message
[pinger]   keepalive starting
[net]      incoming started
[net]      logic started
[net]      logic waiting for msg on ibound
[net]      outgoing stopped
[net]      incoming stopped
13:59:59.158 ConnectionLo ▶ ERROR  Connection Lost: pingresp not received, disconnecting
[client]   enter reconnect
[client]   about to write new connect msg
[client]   socket connected to broker
[client]   Using MQTT 3.1.1 protocol
[net]      connect started
[net]      received connack
[client]   client is reconnected
[net]      outgoing started
[net]      outgoing waiting for an outbound message
[pinger]   keepalive starting
[net]      incoming started
[net]      logic started
[net]      logic waiting for msg on ibound
[pinger]   keepalive sending ping
[net]      Received Message
[net]      logic got msg on ibound
[net]      received pingresp
[net]      logic waiting for msg on ibound
[pinger]   keepalive sending ping
[net]      Received Message
[net]      logic got msg on ibound
[net]      received pingresp
[net]      logic waiting for msg on ibound
[pinger]   keepalive sending ping
[net]      Received Message
[net]      logic got msg on ibound
[net]      received pingresp
[net]      logic waiting for msg on ibound
[pinger]   keepalive sending ping
[net]      Received Message
[net]      logic got msg on ibound
[net]      received pingresp
[net]      logic waiting for msg on ibound
[pinger]   keepalive sending ping
[net]      Received Message
[net]      logic got msg on ibound
[net]      received pingresp
[net]      logic waiting for msg on ibound
[pinger]   keepalive sending ping
[net]      Received Message
[net]      logic got msg on ibound
[net]      received pingresp
[net]      logic waiting for msg on ibound
[pinger]   keepalive sending ping
[net]      Received Message
[net]      logic got msg on ibound
[net]      received pingresp
[net]      logic waiting for msg on bound

28e323f
80999ff
=== RUN   Test_Will                                                                                                                                                                                                                [115/22818]
WARNING  17:50:18 [net]      logic stopped
DEBUG    17:50:18 [client]   Connect()
DEBUG    17:50:18 [client]   about to write new connect msg
DEBUG    17:50:18 [client]   socket connected to broker
DEBUG    17:50:18 [client]   Using MQTT 3.1.1 protocol
DEBUG    17:50:18 [net]      connect started
DEBUG    17:50:18 [net]      received connack
DEBUG    17:50:18 [store]    memorystore initialized
DEBUG    17:50:18 [client]   client is connected
WARNING  17:50:18 [store]    memorystore wiped
DEBUG    17:50:18 [client]   exit startClient
DEBUG    17:50:18 [client]   enter Subscribe
DEBUG    17:50:18 [net]      outgoing started
DEBUG    17:50:18 [net]      logic started
DEBUG    17:50:18 [pinger]   keepalive starting
DEBUG    17:50:18 [client]   SUBSCRIBE: dup: false qos: 1 retain: false rLength: 0MessageID: 0 topics: [/wills]
DEBUG    17:50:18 [client]   exit Subscribe
DEBUG    17:50:18 [net]      incoming started
DEBUG    17:50:18 [client]   Connect()
DEBUG    17:50:18 [client]   about to write new connect msg
DEBUG    17:50:18 [net]      outgoing waiting for an outbound message
DEBUG    17:50:18 [net]      obound priority msg to write, type *packets.SubscribePacket
DEBUG    17:50:18 [net]      outgoing waiting for an outbound message
DEBUG    17:50:18 [net]      logic waiting for msg on ibound
DEBUG    17:50:19 [net]      Received Message
DEBUG    17:50:19 [net]      logic got msg on ibound
DEBUG    17:50:19 [net]      received suback, id: 1
DEBUG    17:50:19 [net]      granted qoss [0]
DEBUG    17:50:19 [net]      logic waiting for msg on ibound
DEBUG    17:50:19 [client]   socket connected to broker
DEBUG    17:50:19 [client]   Using MQTT 3.1.1 protocol
DEBUG    17:50:19 [net]      connect started
DEBUG    17:50:19 [net]      received connack
DEBUG    17:50:19 [store]    memorystore initialized
DEBUG    17:50:19 [client]   client is connected
WARNING  17:50:19 [store]    memorystore wiped
DEBUG    17:50:19 [client]   exit startClient
DEBUG    17:50:19 [net]      outgoing started
DEBUG    17:50:19 [net]      outgoing waiting for an outbound message
DEBUG    17:50:19 [pinger]   keepalive starting
DEBUG    17:50:19 [net]      incoming started
DEBUG    17:50:19 [net]      logic started
DEBUG    17:50:19 [net]      logic waiting for msg on ibound
DEBUG    17:50:20 [client]   forcefully disconnecting
ERROR    17:50:20 [net]      incoming stopped with error
WARNING  17:50:20 [net]      logic stopped
DEBUG    17:50:20 [net]      outgoing stopped
DEBUG    17:50:20 [pinger]   keepalive stopped
DEBUG    17:50:20 [net]      Received Message
DEBUG    17:50:20 [net]      logic got msg on ibound
DEBUG    17:50:20 [net]      received publish, msgId: 0
DEBUG    17:50:20 [net]      putting msg on onPubChan
DEBUG    17:50:20 [net]      done putting msg on incomingPubChan
DEBUG    17:50:20 [net]      logic waiting for msg on ibound
TOPIC: /wills
MSG: good-byte!                           # produced when `wsub` receives the will at fvt_client_test.go:202
DEBUG    17:50:48 [pinger]   keepalive sending ping
DEBUG    17:50:49 [net]      Received Message
DEBUG    17:50:49 [net]      logic got msg on ibound
DEBUG    17:50:49 [net]      received pingresp
DEBUG    17:50:49 [net]      logic waiting for msg on ibound
DEBUG    17:50:59 [pinger]   keepalive sending ping
DEBUG    17:50:59 [net]      Received Message
DEBUG    17:50:59 [net]      logic got msg on ibound
DEBUG    17:50:59 [net]      received pingresp
DEBUG    17:50:59 [net]      logic waiting for msg on ibound
...

  c.pingOutstanding = false

for {
        select {

0c77c5b
fc7cd89
  if err != nil {
      log.Printf("unable to connect : %s", err)
  } else {
      break
  }

[client]   disconnecting
[net]      obound priority msg to write, type *packets.DisconnectPacket
[net]      outbound wrote disconnect, stopping
[net]      logic stopped
[net]      Received Message
[pinger]   keepalive stopped

[client]   disconnecting
[net]      obound priority msg to write, type *packets.DisconnectPacket
[net]      outbound wrote disconnect, stopping
[net]      incoming stopped
[net]      logic stopped
[pinger]   keepalive stopped
[client]   disconnected
[store]    memorystore closed

[client]   sending publish message, topic: /006e77986952ffe946d4db0824b28057/sewise/device_name/device_1
[pinger]   keepalive starting
[net]      outgoing waiting for an outbound message
[net]      incoming started
[net]      obound wrote msg, id: 1
[net]      outgoing waiting for an outbound message
[net]      resetting ping timers
[net]      Received Message
[net]      logic got msg on ibound
[net]      received pubrec, id: 1
[net]      logic waiting for msg on ibound
[net]      obound priority msg to write, type *packets.PubrelPacket
[net]      outgoing waiting for an outbound message
[net]      resetting ping timers
[net]      Received Message
[net]      logic got msg on ibound
[store]    memorystore del: message 1 was deleted
[net]      received pubcomp, id: 1
[net]      incoming stopped with error EOF
[net]      logic waiting for msg on ibound
[net]      logic received from error channel, other components have errored, stopping
[net]      outgoing stopped
[pinger]   keepalive stopped
Connection lost: EOF
[client]   enter reconnect
[client]   about to write new connect msg
[client]   socket connected to broker
[client]   Using MQTT 3.1.1 protocol
[net]      connect started
[net]      received connack
[client]   client is reconnected
[net]      incoming started
[pinger]   keepalive starting
[net]      outgoing started
[net]      outgoing waiting for an outbound message
[net]      logic started
[net]      logic waiting for msg on ibound
[net]      incoming stopped with error EOF
[net]      logic received from error channel, other components have errored, stopping
[pinger]   keepalive stopped
[net]      outgoing stopped
Connection lost: EOF
[client]   enter reconnect
[client]   about to write new connect msg
[client]   socket connected to broker

package main

import (
	"flag"
	"fmt"
	"math/rand"
	"os/signal"
	"syscall"
	"time"

	"log"
	"os"
	"strconv"

	"githubcom/golang/glog"

	MQTT "github.com/eclipse/paho.mqtt.golang"
)

var (
	companyID    = flag.String("cmid", "company_id_1", "company id")
	companyName  = flag.String("cmname", "sewise", "company name")
	device_id    = flag.String("dvid", "device_1", "devices group")
	device_name  = flag.String("dvname", "device_name", "devices group")
	broker       = flag.String("broker", "tcp://127.0.0.1:1883", "The broker URI. ex: tcp://10.10.1.1:1883")
	password     = flag.String("p", "", "The password (optional)")
	user         = flag.String("u", "", "The User (optional)")
	cleansess    = flag.Bool("clean", false, "Set Clean Session (default false)")
	qos          = flag.Int("q", 1, "The Quality of Service 0,1,2 (default 1)")
	num          = flag.Int("num", 1, "The number of messages to publish or subscribe (default 1)")
	payload      = flag.String("m", "open the led", "The message text to publish (default empty)")
	messageCount = flag.Uint("mc", 0, "message count")
	random       = flag.Bool("rand", false, "enable random")
	idmax        = flag.Int("idmax", 1, "random max number")
	sleep        = flag.Int("sleep", 10, "sleep time")
)

func main() {
	MQTT.DEBUG = log.New(os.Stdout, "", 0)
	MQTT.ERROR = log.New(os.Stdout, "", 0)

	flag.Parse()

	// optional
	opts := MQTT.NewClientOptions()
	opts.AddBroker(*broker)
	opts.SetClientID("test_pub")
	opts.SetUsername(*user)
	opts.SetPassword(*password)
	opts.SetCleanSession(*cleansess)
	glog.Infoln("Publisher Started")

	client := MQTT.NewClient(opts)
	if token := client.Connect(); token.Wait() && token.Error() != nil {
		panic(token.Error())
	}
	var dvid string
	t0 := time.Now()
	for i := 1; i <= *num; i++ {
		// log.Println("num:", i)
		if *random {
			rand.Seed(time.Now().UnixNano())
			id := rand.Intn(*idmax) + 1
			dvid = "device_" + strconv.Itoa(id)
		} else {
			dvid = *device_id
		}

		topic := fmt.Sprintf("/%s/%s/%s/%s", *companyID, *companyName, *device_name, dvid)
		err := publish(client, *qos, topic, *payload)

		if err != nil {
			glog.Errorln("publish error: ", err)
		}
		s := time.Duration(*sleep)
		time.Sleep(time.Millisecond * s)
	}
	t := time.Since(t0)
	// client.Disconnect(50)
	log.Println("Publisher Done, total time:", t)
	ch := make(chan os.Signal)
	signal.Notify(ch, syscall.SIGINT)
	sig := <-ch
	fmt.Printf("Signal received: %v\n", sig)
}

func publish(client MQTT.Client, qos int, top, payload string) error {
	(*messageCount)++
	p := fmt.Sprintf("[%d]_%s", *messageCount, payload)
	token := client.Publish(top, byte(qos), false, p)
	if token.Error() != nil {
		return token.Error()
	}
	token.WaitTimeout(time.Millisecond * 100)
	glog.Errorf("count: %d, [OnSend] topic=>%s message=>%s", *messageCount, top, p)
	return nil
}
5687bf8
617c801

eclipse / paho.mqtt.golang Goto Github PK

paho.mqtt.golang's Introduction

Eclipse Paho MQTT Go client

Installation and Build

Modules

GOPATH

Usage and API

Troubleshooting

Error Handling

Logging

Common Problems

Reporting bugs

Contributing

More information

paho.mqtt.golang's People

Contributors

Stargazers

Watchers

Forkers

paho.mqtt.golang's Issues

That implemantation is as follows;

}

Here is my sample program.

}

go version go1.4.2 darwin/amd64

exit status 2

(trusty)ezbercih@localhost:~/code/go/src/mqtt$ go run -race simple.go

/home/ezbercih/code/go/src/mqtt/simple.go:35 +0xfd

<----- keepalive does not sending ping until here ------->

I get the following trace when I try to connect with SetCleanSession(false). Things work fine with SetCleanSession(true).

goroutine 17 [syscall]: runtime.goexit() /usr/local/go/src/pkg/runtime/proc.c:1445 exit status 2

Recommend Projects

Recommend Topics

Recommend Org

goroutine 17 [syscall]:
runtime.goexit()
/usr/local/go/src/pkg/runtime/proc.c:1445
exit status 2