Make sure to close the sockets

2013/zmq/go/rep-server-crashy/main.go

@@ -4,7 +4,9 @@ import zmq "github.com/alecthomas/gozmq"
 
 func main() {
 	context, _ := zmq.NewContext()
+	defer context.Close()
 	socket, _ := context.NewSocket(zmq.REP)
+	defer socket.Close()
 	socket.Bind("tcp://127.0.0.1:5000")
 
 	for {

2013/zmq/go/rep-server/main.go

@@ -4,7 +4,9 @@ import zmq "github.com/alecthomas/gozmq"
 
 func main() {
 	context, _ := zmq.NewContext()
+	defer context.Close()
 	socket, _ := context.NewSocket(zmq.REP)
+	defer socket.Close()
 	socket.Bind("tcp://127.0.0.1:5000")
 
 	for {

2013/zmq/go/req-client/main.go

@@ -1,17 +1,24 @@
 package main
 
-import "fmt"
-import zmq "github.com/alecthomas/gozmq"
+import (
+	"fmt"
+	zmq "github.com/alecthomas/gozmq"
+	"time"
+)
 
 func main() {
 	context, _ := zmq.NewContext()
+	defer context.Close()
 	socket, _ := context.NewSocket(zmq.REQ)
+	defer socket.Close()
 	socket.Connect("tcp://127.0.0.1:5000")
 
 	for i := 0; i < 10; i++ {
+		time.Sleep(100 * time.Millisecond)
 		msg := fmt.Sprintf("msg %d", i)
 		socket.Send([]byte(msg), 0)
 		println("Sending", msg)
-		socket.Recv(0)
+		data, _ := socket.Recv(0)
+		println("Got", string(data))
 	}
 }