// Set a connection name
nc, err := nats.Connect("demo.nats.io", nats.Name("API Name Example"))
if err != nil {
log.Fatal(err)
}
defer nc.Close()
// Do something with the connection
Options options = new Options.Builder().
server("nats://demo.nats.io:4222").
connectionName("my-connection"). // Set a connection name
build();
Connection nc = Nats.connect(options);
// Do something with the connection
nc.close();
let nc = NATS.connect({
url: "nats://demo.nats.io:4222",
name: "my-connection"
});
nc = NATS()
await nc.connect(servers=["nats://demo.nats.io:4222"], name="my-connection")
# Do something with the connection.
require 'nats/client'
NATS.start(servers:["nats://demo.nats.io:4222"], name: "my-connection") do |nc|
nc.on_reconnect do
puts "Got reconnected to #{nc.connected_server}"
end
nc.on_disconnect do |reason|
puts "Got disconnected! #{reason}"
end
nc.close
end
// will throw an exception if connection fails
let nc = await connect({
url: "nats://demo.nats.io:4222",
name: "my-connection"
});
nc.close();