Listening for Reconnect Events

    {% tabs %} {% tab title=”Go” %}

    {% endtab %}

    {% tab title=”Java” %}

    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
    15. nc.close();

    {% tab title=”JavaScript” %}

    {% endtab %}

    {% tab title=”Python” %}

    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.
    9. await nc.connect(
    10.    servers=["nats://demo.nats.io:4222"],
    11.    reconnect_time_wait=10,
    12.    reconnected_cb=reconnected_cb,
    13.    disconnected_cb=disconnected_cb,
    14.    )
    16. # Do something with the connection.

    {% tab title=”Ruby” %}

    {% endtab %}

    {% tab title=”C” %}

    1. static void
    2. disconnectedCB(natsConnection *conn, void *closure)
    3. {
    4.     // Handle disconnect error event
    5. }
    7. static void
    8. reconnectedCB(natsConnection *conn, void *closure)
    9. {
    10.     // Handle reconnect event
    11. }
    14. natsConnection      *conn      = NULL;
    15. natsOptions         *opts      = NULL;
    16. natsStatus          s          = NATS_OK;
    18. s = natsOptions_Create(&opts);
    20. // Connection event handlers are invoked asynchronously
    21. // and the state of the connection may have changed when
    22. // the callback is invoked.
    23. if (s == NATS_OK)
    24.     s = natsOptions_SetDisconnectedCB(opts, disconnectedCB, NULL);
    25. if (s == NATS_OK)
    26.     s = natsOptions_SetReconnectedCB(opts, reconnectedCB, NULL);
    28. if (s == NATS_OK)
    29.     s = natsConnection_Connect(&conn, opts);
    31. (...)
    33. // Destroy objects that were created
    35. natsOptions_Destroy(opts);