code: public static StreamingConnection connect(String clusterId, String clientId)
              throws IOException, InterruptedException {
          return connect(clusterId, clientId, defaultOptions());
      }
docs: Creates a NATS Streaming connection using the supplied cluster ID and client ID.
  
  @param clusterId the NATS Streaming cluster ID
  @param clientId  the NATS Streaming client ID
  @return the {@link StreamingConnection}
  @throws IOException          if a problem occurs
  @throws InterruptedException if the calling thread is interrupted before the connection
  attempt succeeds