zmq / poller / proxy

zmq.go

poller := zmq.NewPoller()
poller.Add(frontend, zmq.POLLIN)
poller.Add(backend, zmq.POLLIN)

for {
var sockets []zmq.Polled

sockets, err := poller.Poll(-1)
if err != nil {
 break
}

for _, socket := range sockets {
  switch socket.Socket {
    case frontend:
      msg, err := frontend.RecvMessage(0)
      if err != nil {
         break
      }
      backend.SendMessage(msg)
    case backend:
      msg, err := backend.RecvMessage(0)
      if err != nil {
         break
      }
      frontend.SendMessage(msg)
    }
  }
}

// Is this poller implementation the same as the native zmq proxy?

err := zmq.Proxy(frontend, backend, nil)
fmt.Printf("Proxy interrupted: %v\n", err)