go-nsq-producer-test.go

package main

import (
  "log"
  "time"
  
  "github.com/bitly/go-nsq"
)

const (
  addr    = "127.0.0.1:4150"
  topic   = "ex_topic"
  message = "ex_body"
)

func main() {
  config := nsq.NewConfig()
  producer, err := nsq.NewProducer(addr, config)
  if err != nil {
    log.Fatal(err)
  }
  err = producer.Publish(topic, []byte(message))
  if err != nil {
    log.Fatal(err)
  }
  producer.Stop()
  
  time.Sleep(3 * time.Second)
}