Merge pull request #315 from jtacoma/gozmqfix

Update Go examples for new gozmq API.
booksbyus · Mar 26, 2013 · 4ddb7a0 · 4ddb7a0
2 parents 469294a + 0c6a3f9
commit 4ddb7a0
Show file tree

Hide file tree

Showing 6 changed files with 9 additions and 9 deletions.
diff --git a/examples/Go/identity.go b/examples/Go/identity.go
@@ -10,7 +10,7 @@ import (
 	zmq "github.com/alecthomas/gozmq"
 )
 
-func dump(sink zmq.Socket) {
+func dump(sink *zmq.Socket) {
 	parts, err := sink.RecvMultipart(0)
 	if err != nil {
 		fmt.Println(err)

diff --git a/examples/Go/lbbroker.go b/examples/Go/lbbroker.go
@@ -26,7 +26,7 @@ func randomString() string {
 	return strings.Join(target, "")
 }
 
-func set_id(socket zmq.Socket) {
+func set_id(socket *zmq.Socket) {
 	socket.SetSockOptString(zmq.IDENTITY, randomString())
 }
 

diff --git a/examples/Go/mdbroker.go b/examples/Go/mdbroker.go
@@ -44,10 +44,10 @@ type mdService struct {
 }
 
 type mdBroker struct {
-	context     zmq.Context           //  Context
+	context     *zmq.Context          //  Context
 	heartbeatAt time.Time             //  When to send HEARTBEAT
 	services    map[string]*mdService //  Known services
-	socket      zmq.Socket            //  Socket for clients & workers
+	socket      *zmq.Socket           //  Socket for clients & workers
 	waiting     *ZList                //  Idle workers
 	workers     map[string]*mdbWorker //  Known workers
 	verbose     bool                  //  Print activity to stdout

diff --git a/examples/Go/mdcliapi.go b/examples/Go/mdcliapi.go
@@ -19,8 +19,8 @@ type Client interface {
 
 type mdClient struct {
 	broker  string
-	client  zmq.Socket
-	context zmq.Context
+	client  *zmq.Socket
+	context *zmq.Context
 	retries int
 	timeout time.Duration
 	verbose bool

diff --git a/examples/Go/mdwrkapi.go b/examples/Go/mdwrkapi.go
@@ -19,10 +19,10 @@ type Worker interface {
 
 type mdWorker struct {
 	broker  string
-	context zmq.Context
+	context *zmq.Context
 	service string
 	verbose bool
-	worker  zmq.Socket
+	worker  *zmq.Socket
 
 	heartbeat   time.Duration
 	heartbeatAt time.Time

diff --git a/examples/Go/ppworker.go b/examples/Go/ppworker.go
@@ -26,7 +26,7 @@ const (
 //  Helper function that returns a new configured socket
 //  connected to the Paranoid Pirate queue
 
-func WorkerSocket(context zmq.Context) zmq.Socket {
+func WorkerSocket(context *zmq.Context) *zmq.Socket {
 	worker, _ := context.NewSocket(zmq.DEALER)
 	worker.Connect("tcp://localhost:5556")