InnerPublisherSubscription needs to handle Throwable on subscription request

If there is an exception when invoking a the initial command for the cluster publisher the exception is silently ignored by RxJava and just logged. We should instead propagate the exception properly so users are aware of any issues.