diff --git a/cmd/client/README.md b/cmd/ingest/README.md similarity index 100% rename from cmd/client/README.md rename to cmd/ingest/README.md diff --git a/cmd/client/zmq_client.go b/cmd/ingest/main.go similarity index 98% rename from cmd/client/zmq_client.go rename to cmd/ingest/main.go index 2c65126..5d5f157 100644 --- a/cmd/client/zmq_client.go +++ b/cmd/ingest/main.go @@ -124,6 +124,8 @@ func main() { } defer sock.Close() + log.Printf("Listening to 0mq on %s", opts.zmqAddr) + // Start listening for new blocks for { msg, err := sock.RecvMessageBytes(0)