2 Commits

Author SHA1 Message Date
Georg K
c8bcc8f44c chore: update logging; bump: v0.0.6 2022-03-18 18:49:16 +03:00
Georg K
b45986145c fix: package name to gitlab.connectone.pro/github/nats-transport`; bump: 0.0.4 2022-03-18 18:35:45 +03:00
2 changed files with 4 additions and 4 deletions

2
go.mod
View File

@@ -1,4 +1,4 @@
module github.com/jar3b/nats-transport module gitlab.connectone.pro/github/nats-transport
go 1.17 go 1.17

View File

@@ -71,17 +71,17 @@ func (nt NatsTransport) RoundTrip(r *http.Request) (*http.Response, error) {
// Get Response object from NATS message // Get Response object from NATS message
response := NewResponse() response := NewResponse()
if err := response.ReadFrom(msg.Data); err != nil { 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 != "" { 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 // prepare HTTP response
httpResponse, err := response.ToHTTPResponse(r) httpResponse, err := response.ToHTTPResponse(r)
if err != nil { 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 return httpResponse, nil