goczmq
goczmq copied to clipboard
zeromq
goczmq is a golang wrapper for CZMQ.
go build -tags 'goczmq' main.go # pkg-config --cflags -- libczmq libzmq libsodium Package libczmq was not found in the pkg-config search path. Perhaps you should add the directory containing `libczmq.pc'...
Sometimes call `RecvMessage()` return `recv frame error` and `SendFrame()` return `send frame error`. But just retry call fix this problem. Steps to reproduce: run this program (`for` loop is important...
I get an inconsistent, occasional SIGABRT on calling newReq(). The program opens many request lines, so my initial guess is that calling newReq from many goroutines at once is causing...
Was trying a goczmq based implementation of the mtserver example in https://zguide.zeromq.org/docs/chapter2/ and found that there's currently no wrapper around zmq_device.
## Background The `github.com/zeromq/goczmq` uses [Go modules](https://github.com/golang/go/wiki/Modules) and the current release version is `v4`. And it’s module path is `"github.com/zeromq/goczmq"`, instead of `"github.com/zeromq/goczmq/v4"`. It must comply with the specification of...
Having trouble getting goczmq working on MacOS Big Sur: Environment: MacOS Big Sur Version 11.0.1 go version go1.15.5 darwin/amd64 Installed Prerequisites: brew install libsodium brew install czmq brew install zeromq...
server ``` package main import ( "fmt" "math/rand" "time" czmq "github.com/zeromq/goczmq" ) func main() { pubEndpoint := "tcp://*:5556" pubSock, err := czmq.NewPub(pubEndpoint) if err != nil { panic(err) } defer...
`Poller.Remove()` doesn't actually remove the given socket from the underlying czmq poller, it just removes it from the slice of golang objects wrapping sockets. While I can't explain the exact...
This seems to happen when cleaning up tests. Context: In my test, I have a `defer c.Destroy()` where `c` is a `Channeler`. This seems to occasionally (maybe ~10% of the...
