Subscription command issue? about miniqueue HOT 3 CLOSED

miniqueue % go run echo.go 
> foo
Published message foo to topic test_topic
Consumed message: foo
> bar
Published message bar to topic test_topic
Consumed message: bar
> hello there
Published message hello there to topic test_topic
Consumed message: hello there
> 

4:14PM INF starting miniqueue port=:9999
4:14PM INF publishing to topic handler=publish request_id=c1397irrbdg6m98fropg topic=test_topic
4:14PM INF subscribing to topic handler=subscribe request_id=c1397irrbdg6m98froq0 topic=test_topic
4:14PM INF client disconnected while waiting for message cmd=ACK handler=subscribe request_id=c1397irrbdg6m98froq0 topic=test_topic
4:14PM ERR failed decoding command error=EOF handler=subscribe request_id=c1397irrbdg6m98froq0 topic=test_topic
4:15PM INF publishing to topic handler=publish request_id=c1397lrrbdg6m98fror0 topic=test_topic
4:15PM INF subscribing to topic handler=subscribe request_id=c1397lrrbdg6m98frorg topic=test_topic
4:15PM INF client disconnected while waiting for message cmd=ACK handler=subscribe request_id=c1397lrrbdg6m98frorg topic=test_topic
4:15PM ERR failed decoding command error=EOF handler=subscribe request_id=c1397lrrbdg6m98frorg topic=test_topic
4:15PM INF publishing to topic handler=publish request_id=c1397q3rbdg6m98frosg topic=test_topic
4:15PM INF subscribing to topic handler=subscribe request_id=c1397q3rbdg6m98frot0 topic=test_topic
4:15PM INF client disconnected while waiting for message cmd=ACK handler=subscribe request_id=c1397q3rbdg6m98frot0 topic=test_topic
4:15PM ERR failed decoding command error=EOF handler=subscribe request_id=c1397q3rbdg6m98frot0 topic=test_topic

curl --insecure --cacert certs/ca.key --key certs/node.key --cert certs/node.crt -X POST https://localhost:9999/subscribe/foo -d "\"INIT\""