Including a Reply Subject

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

    {% endtab %}

    {% tab title=”Java” %}

    1. Connection nc = Nats.connect("nats://demo.nats.io:4222");
    3. // Create a unique subject name
    4. String uniqueReplyTo = NUID.nextGlobal();
    6. // Listen for a single response
    7. Subscription sub = nc.subscribe(uniqueReplyTo);
    8. sub.unsubscribe(1);
    10. // Send the request
    11. nc.publish("time", uniqueReplyTo, null);
    13. // Read the reply
    14. Message msg = sub.nextMessage(Duration.ofSeconds(1));
    16. System.out.println(new String(msg.getData(), StandardCharsets.UTF_8));
    18. // Close the connection
    19. nc.close();

    {% tab title=”JavaScript” %}

    {% endtab %}

    {% tab title=”Python” %}

    1. nc = NATS()
    3. future = asyncio.Future()
    5. async def sub(msg):
    6.   nonlocal future
    7.   future.set_result(msg)
    9. await nc.connect(servers=["nats://demo.nats.io:4222"])
    10. await nc.subscribe("time", cb=sub)
    12. await nc.publish("time", b'', unique_reply_to)
    14. # Use the response
    15. msg = await asyncio.wait_for(future, 1)
    16. print("Reply:", msg)

    {% tab title=”Ruby” %}

    {% endtab %}

    {% tab title=”C” %}

    1. natsConnection      *conn      = NULL;
    2. natsStatus          s          = NATS_OK;
    4. s = natsConnection_ConnectTo(&conn, NATS_DEFAULT_URL);
    5. // Publish a message and provide a reply subject
    6. if (s == NATS_OK)
    7.     s = natsConnection_PublishRequestString(conn, "request", "reply", "this is the request");
    9. (...)
    11. natsConnection_Destroy(conn);