Message queue and persistence with Go client