Sending Structured Data
Take a simple stock ticker that sends the symbol and price of each stock:
{% tabs %} {% tab title=”Go” %}
{% endtab %}
public String symbol;
public float price;
}
public class PublishJSON {
public static void main(String[] args) {
try {
Connection nc = Nats.connect("nats://demo.nats.io:4222");
// Create the data object
stk.price=1200;
// use Gson to encode the object to JSON
GsonBuilder builder = new GsonBuilder();
Gson gson = builder.create();
String json = gson.toJson(stk);
// Publish the message
nc.publish("updates", json.getBytes(StandardCharsets.UTF_8));
nc.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
{% endtab %}
{% tab title=”JavaScript” %}
{% endtab %}
nc = NATS()
await nc.connect(servers=["nats://demo.nats.io:4222"])
{% endtab %}
{% tab title=”Ruby” %}
{% endtab %}
{% endtab %} {% endtabs %}