Use data directory for storing zeromq river status
Full rewrite of Elastricsearch river zeromq