Fast message broker implemented with Golang programming language. Using no external libraries, just internal Golang libraries.
How to use?
Get package:
go get github.com/amirhnajafiz/stallion
Client
package main
import (
"fmt"
"time"
"github.com/amirhnajafiz/stallion"
)
func main() {
client, err := stallion.NewClient("localhost:9090")
if err != nil {
panic(err)
}
client.Subscribe("topic", func(data []byte) {
fmt.Println(string(data))
})
client.Publish("topic", []byte("Hello"))
time.Sleep(3 * time.Second)
}
Server
package main
import "github.com/amirhnajafiz/stallion"
func main() {
if err := stallion.NewServer(":9090"); err != nil {
panic(err)
}
}
