code: public static StreamingConnection connect(
              String clusterId, String clientId, Options opts)
              throws IOException, InterruptedException {
          try {
              StreamingConnectionImpl conn = new StreamingConnectionImpl(clusterId, clientId, opts);
              conn.connect();
              return conn;
          } catch (InterruptedException e) {
              Thread.currentThread().interrupt();
              return null;
          }
      }
docs: Creates a NATS Streaming connection using the supplied cluster ID, client ID, and
  {@link Options}.
  
  @param clusterId the NATS Streaming cluster ID
  @param clientId  the NATS Streaming client ID
  @param opts      the configuration {@link Options}
  @return the {@link StreamingConnection}
  @throws IOException          if a problem occurs
  @throws InterruptedException if the calling thread is interrupted before the connection
  attempt succeeds