Skip to content

Commit

Permalink
all: migrate to gopkg.in/zeromq/goczmq.v4
Browse files Browse the repository at this point in the history
  • Loading branch information
sbinet committed Jul 4, 2019
1 parent 60c9e9e commit 5f0b4c3
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 6 deletions.
4 changes: 2 additions & 2 deletions cxx_zmq4_compat.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ import (
"context"
"net"

czmq4 "github.com/zeromq/goczmq"
czmq4 "gopkg.in/zeromq/goczmq.v4"
)

func NewCPair(ctx context.Context, opts ...czmq4.SockOption) Socket {
Expand Down Expand Up @@ -145,7 +145,7 @@ func (sck *csocket) SetOption(name string, value interface{}) error {
return nil
case OptionUnsubscribe:
topic := value.(string)
sck.sock.SetUnsubscribe(topic)
sck.sock.SetOption(czmq4.SockSetUnsubscribe(topic))
return nil
default:
panic("unknown set option name [" + name + "]")
Expand Down
7 changes: 4 additions & 3 deletions go.mod
Original file line number Diff line number Diff line change
@@ -1,7 +1,8 @@
module github.com/go-zeromq/zmq4

go 1.12

require (
github.com/pkg/errors v0.8.0
golang.org/x/net v0.0.0-20180629035331-4cb1c02c05b0
golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f
github.com/pkg/errors v0.8.1
golang.org/x/sync v0.0.0-20190423024810-112230192c58
)
2 changes: 1 addition & 1 deletion security/plain/plain_cxx_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,8 +16,8 @@ import (
"github.com/go-zeromq/zmq4"
"github.com/go-zeromq/zmq4/security/plain"
"github.com/pkg/errors"
czmq4 "github.com/zeromq/goczmq"
"golang.org/x/sync/errgroup"
czmq4 "gopkg.in/zeromq/goczmq.v4"
)

func TestMain(m *testing.M) {
Expand Down

0 comments on commit 5f0b4c3

Please sign in to comment.