Structured Data

    For example, to receive JSON you could do:

    Go

    2.     public String symbol;
    3.     public float price;
    5.     public String toString() {
    6.         return symbol + " is at " + price;
    7.     }
    8. }
    10. public class SubscribeJSON {
    11.     public static void main(String[] args) {
    13.         try {
    14.             Connection nc = Nats.connect("nats://demo.nats.io:4222");
    16.             // Use a latch to wait for 10 messages to arrive
    17.             CountDownLatch latch = new CountDownLatch(10);
    19.             // Create a dispatcher and inline message handler
    20.             Dispatcher d = nc.createDispatcher((msg) -> {
    21.                 Gson gson = new Gson();
    23.                 String json = new String(msg.getData(), StandardCharsets.UTF_8);
    25.                 // Use the object
    26.                 System.out.println(stk);
    28.                 latch.countDown();
    29.             });
    31.             // Subscribe
    32.             d.subscribe("updates");
    34.             // Wait for a message to come in
    35.             latch.await(); 
    37.             // Close the connection
    38.             nc.close();
    39.         } catch (Exception e) {
    40.             e.printStackTrace();
    41.         }
    42.     }
    43. }

    JavaScript

    Python

    1. import asyncio
    2. import json
    3. from nats.aio.client import Client as NATS
    5. async def run(loop):
    6.     nc = NATS()
    8.     await nc.connect(servers=["nats://127.0.0.1:4222"], loop=loop)
    10.     async def message_handler(msg):
    11.         data = json.loads(msg.data.decode())
    12.         print(data)
    14.     sid = await nc.subscribe("updates", cb=message_handler)
    15.     await nc.flush()
    17.     await nc.auto_unsubscribe(sid, 2)
    18.     await nc.publish("updates", json.dumps({"symbol": "GOOG", "price": 1200 }).encode())
    19.     await asyncio.sleep(1, loop=loop)
    20.     await nc.close()

    TypeScript

    1. let nc = await connect({
    2.     url: "nats://demo.nats.io:4222",
    3.     payload: Payload.JSON
    4. });
    6. nc.subscribe('updates', (err, msg) => {

    C