public static StreamingConnection connect ( String clusterId , String clientId ) throws IOException , InterruptedException { return connect ( clusterId , clientId , defaultOptions ( ) ) ; }
Creates a NATS Streaming connection using the supplied cluster ID and client ID .