pub/nats-transport
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

chore: update logging; bump: v0.0.6

Browse Source
This commit is contained in:
Georg K 2022-03-18 18:49:16 +03:00
parent b45986145c
commit c8bcc8f44c
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
transport.go
View File

@ -71,17 +71,17 @@ func (nt NatsTransport) RoundTrip(r *http.Request) (*http.Response, error) {
// Get Response object from NATS message
response := NewResponse()
if err := response.ReadFrom(msg.Data); err != nil {
return nil, fmt.Errorf("nats_transport: %v", err)
return nil, fmt.Errorf("nats_transport: cannot read response from NATS: %v", err)
}
if response.Error != "" {
return nil, fmt.Errorf("nats_transport: %s", response.Error)
return nil, fmt.Errorf("nats_transport: NATS returns an error: %s", response.Error)
}
// prepare HTTP response
httpResponse, err := response.ToHTTPResponse(r)
if err != nil {
return nil, fmt.Errorf("nats_transport: %v", err)
return nil, fmt.Errorf("nats_transport: cannot convert to HTTP response: %v", err)
}
return httpResponse, nil