Listening for Reconnect Events

    Go

    2.                             server("nats://demo.nats.io:4222").
    3.                             connectionListener((conn, type) -> {
    4.                                 if (type == Events.RECONNECTED) {
    5.                                     // handle reconnected
    6.                                 } else if (type == Events.DISCONNECTED) {
    7.                                     // handle disconnected, wait for reconnect
    8.                                 }
    9.                             }).
    10.                             build();
    11. Connection nc = Nats.connect(options);
    13. // Do something with the connection

    JavaScript

    1. nc = NATS()
    3. async def disconnected_cb():
    4.    print("Got disconnected!")
    6. async def reconnected_cb():
    7.    # See who we are connected to on reconnect.
    8.    print("Got reconnected to {url}".format(url=nc.connected_url.netloc))
    10. await nc.connect(
    11.    servers=["nats://demo.nats.io:4222"],
    12.    reconnect_time_wait=10,
    13.    reconnected_cb=reconnected_cb,
    16. # Do something with the connection.

    Ruby

    1. // will throw an exception if connection fails
    2. let nc = await connect({
    3.     maxReconnectAttempts: 10,
    4.     servers: ["nats://demo.nats.io:4222"]
    5. });
    6. // first argument is the connection (same as nc in this case)
    7. // second argument is the url of the server where the client
    8. // connected
    9. nc.on('reconnect', (conn, server) => {
    10.     console.log('reconnected to', server);
    12. nc.close();

    C