onMsg(natsConnection *conn, natsSubscription *sub, natsMsg *msg, void *closure)
printf("Received msg: %s - %.*s\n",
natsMsg_GetDataLength(msg),
// Need to destroy the message!
natsConnection *conn = NULL;
natsSubscription *sub = NULL;
s = natsConnection_ConnectTo(&conn, NATS_DEFAULT_URL);
// Create a queue subscription on "updates" with queue name "workers"
s = natsConnection_QueueSubscribe(&sub, conn, "updates", "workers", onMsg, NULL);
// Destroy objects that were created
natsSubscription_Destroy(sub);
natsConnection_Destroy(conn);