fsm_client_example.go

nc, _ := nats.Connect(nats.DefaultURL)

body := []byte(`{"status":"verification_pending", "verification_done"}`)
msg, err := nc.Request("workflow.get.next", body, 10*time.Millisecond)

nc.Close();

fsm_server_example.go

nc, _ := nats.Connect(nats.DefaultURL)

nc.Subscribe("workflow.get.next", func(m *Msg) {
    workflow := loadWorkflow("config.json")
    status, event, err := prepare(m.Data)
    if err != nil {
      nc.Publish(m.Reply, []byte("error"))
      return
    }
    if next, err := workflow.getNext(status, event); err != nil {
      nc.Publish(m.Reply, []byte(next))
    }
})