Options options = new Options.Builder(). server("nats://localhost:4222"). authHandler(Nats.credentials("path_to_creds_file")). build(); Connection nc = Nats.connect(options); // Do something with the connection nc.close();