natsx

Natswrap

natsx is a simple wrapper for nats.io client.

Usage

To start use the natsx package add import:

...
import (
  "github.com/lancer-kit/armory/natsx"
)
...

• Fill config structure:

• Set config:

natsx.SetCfg(cfg)

Connect will be initialized at first try to push or subscribe a message

err := PublishMessage(topic, obj)

Example

package main

import (
    "fmt"
    "github.com/lancer-kit/armory/natsx"
)

var config = natsx.Config{
    Host: "127.0.0.1",
    Port: 4222,
    User: "user",
    Password: "password",  
}

err := config.Validate()
if err != nil {
    fmt.Println('invalid nats configuration')
}

natsx.SetConfig(&config)

testMsg := []string {"1", "2"}
err := natsx.PublishMessage("Topic", testMsg)
if err != nil {
    log.Get().Error(err)
}