diff --git a/services/rabbitmq/oas_commit b/services/rabbitmq/oas_commit index 200235745..69bfa80b3 100644 --- a/services/rabbitmq/oas_commit +++ b/services/rabbitmq/oas_commit @@ -1 +1 @@ -615e0c091b55fd1ae8e4931c26902127bddf6ac6 +864bdad12a54f612df8fcdb6e41dd2933e94c3af diff --git a/services/rabbitmq/v1api/client.go b/services/rabbitmq/v1api/client.go index 9aaa3e554..f8157eb8f 100644 --- a/services/rabbitmq/v1api/client.go +++ b/services/rabbitmq/v1api/client.go @@ -461,6 +461,15 @@ func (c *APIClient) decode(v interface{}, b []byte, contentType string) (err err *s = string(b) return nil } + if r, ok := v.(*io.Reader); ok { + *r = bytes.NewReader(b) + return nil + } + // Must stay before the JSON branch: json.Unmarshal would base64-decode into *[]byte. + if p, ok := v.(*[]byte); ok { + *p = b + return nil + } if f, ok := v.(*os.File); ok { f, err = os.CreateTemp("", "HttpClientFile") if err != nil { diff --git a/services/rabbitmq/v2api/client.go b/services/rabbitmq/v2api/client.go index dc2c69b74..1ce0d599d 100644 --- a/services/rabbitmq/v2api/client.go +++ b/services/rabbitmq/v2api/client.go @@ -461,6 +461,15 @@ func (c *APIClient) decode(v interface{}, b []byte, contentType string) (err err *s = string(b) return nil } + if r, ok := v.(*io.Reader); ok { + *r = bytes.NewReader(b) + return nil + } + // Must stay before the JSON branch: json.Unmarshal would base64-decode into *[]byte. + if p, ok := v.(*[]byte); ok { + *p = b + return nil + } if f, ok := v.(*os.File); ok { f, err = os.CreateTemp("", "HttpClientFile") if err != nil {