Need to check for connectivity when initialising the sinks, throwing exceptions if this fails.
Need to check for connectivity when initialising the sinks, throwing exceptions if this fails.