Move shared functionality into a utility namespace.
Remove constant reconnect calls.
Add cassandra usage.