taigrr/nats.docs
1
0
Fork 0
mirror of https://github.com/taigrr/nats.docs synced 2025-01-18 04:03:23 -08:00
Code Issues Projects Releases Wiki Activity

Merge pull request #18 from philpennock/patch-1

Browse Source 
structured data: Go: handle decode errors
This commit is contained in:
Ginger Collison 2019-12-19 09:11:47 -06:00 committed by GitHub
commit 1adc0271aa
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
developing-with-nats/receiving/structure.md
View File

@ -7,7 +7,14 @@ For example, to receive JSON you could do:
{% tabs %} {% tabs %}
{% tab title="Go" %} {% tab title="Go" %}
```go ```go
nc, err := nats.Connect("demo.nats.io") nc, err := nats.Connect("demo.nats.io",
nats.ErrorHandler(func(nc *nats.Conn, s *nats.Subscription, err error) {
if s != nil {
log.Printf("Async error in %q/%q: %v", s.Subject, s.Queue, err)
} else {
log.Printf("Async error outside subscription: %v", err)
}
}))
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)
} }
@ -28,6 +35,9 @@ wg := sync.WaitGroup{}
wg.Add(1) wg.Add(1)
// Subscribe // Subscribe
// Decoding errors will be passed to the function supplied via
// nats.ErrorHandler above, and the callback supplied here will
// not be invoked.
if _, err := ec.Subscribe("updates", func(s *stock) { if _, err := ec.Subscribe("updates", func(s *stock) {
log.Printf("Stock: %s - Price: %v", s.Symbol, s.Price) log.Printf("Stock: %s - Price: %v", s.Symbol, s.Price)
wg.Done() wg.Done()