Structured Data

For example, to receive JSON you could do:

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

{% endtab %}

    public String symbol;
    public float price;
    public String toString() {
        return symbol + " is at " + price;
    }
}
public class SubscribeJSON {
    public static void main(String[] args) {
        try {
            Connection nc = Nats.connect("nats://demo.nats.io:4222");
            // Use a latch to wait for 10 messages to arrive
            CountDownLatch latch = new CountDownLatch(10);
            // Create a dispatcher and inline message handler
            Dispatcher d = nc.createDispatcher((msg) -> {
                Gson gson = new Gson();
                StockForJsonSub stk = gson.fromJson(json, StockForJsonSub.class);
                // Use the object
                System.out.println(stk);
                latch.countDown();
            });
            // Subscribe
            d.subscribe("updates");
            // Wait for a message to come in
            latch.await(); 
            // Close the connection
            nc.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

{% endtab %}

{% tab title=”JavaScript” %}

{% endtab %}

import json
from nats.aio.client import Client as NATS
from nats.aio.errors import ErrTimeout
async def run(loop):
    nc = NATS()
    await nc.connect(servers=["nats://127.0.0.1:4222"], loop=loop)
    async def message_handler(msg):
        data = json.loads(msg.data.decode())
        print(data)
    sid = await nc.subscribe("updates", cb=message_handler)
    await nc.flush()
    await nc.auto_unsubscribe(sid, 2)
    await nc.publish("updates", json.dumps({"symbol": "GOOG", "price": 1200 }).encode())
    await asyncio.sleep(1, loop=loop)
    await nc.close()

{% endtab %}

{% tab title=”Ruby” %}

{% endtab %}

{% endtab %} {% endtabs %}