diff --git a/ers/amqpv1.go b/ers/amqpv1.go index 6f42bbb39..4d853bab2 100644 --- a/ers/amqpv1.go +++ b/ers/amqpv1.go @@ -128,7 +128,7 @@ func (rdr *AMQPv1ER) readLoop(recv *amqpv1.Receiver) (err error) { rdr.rdrErr <- err return } - if err = msg.Accept(ctx); err != nil { + if err = recv.AcceptMessage(ctx, msg); err != nil { utils.Logger.Warning( fmt.Sprintf("<%s> unable to accept message error: %s", utils.ERs, err.Error())) diff --git a/go.mod b/go.mod index 422446786..47b55f1b8 100644 --- a/go.mod +++ b/go.mod @@ -13,7 +13,7 @@ go 1.18 // replace github.com/cgrates/aringo => ../aringo require ( - github.com/Azure/go-amqp v0.15.0 + github.com/Azure/go-amqp v0.17.5 github.com/antchfx/xmlquery v1.3.3 github.com/aws/aws-sdk-go v1.36.24 github.com/blevesearch/bleve v1.0.14 diff --git a/go.sum b/go.sum index eedfcb9f9..1f0c288cb 100644 --- a/go.sum +++ b/go.sum @@ -34,8 +34,8 @@ cloud.google.com/go/storage v1.6.0/go.mod h1:N7U0C8pVQ/+NIKOBQyamJIeKQKkZ+mxpohl cloud.google.com/go/storage v1.8.0/go.mod h1:Wv1Oy7z6Yz3DshWRJFhqM/UCfaWIRTdp0RXyy7KQOVs= cloud.google.com/go/storage v1.10.0/go.mod h1:FLPqc6j+Ki4BU591ie1oL6qBQGu2Bl/tZ9ullr3+Kg0= dmitri.shuralyov.com/gpu/mtl v0.0.0-20190408044501-666a987793e9/go.mod h1:H6x//7gZCb22OMCxBHrMx7a5I7Hp++hsVxbQ4BYO7hU= -github.com/Azure/go-amqp v0.15.0 h1:YcB++F5msgyl8htdsjjlhK132YFca31FBPB7lObE/p0= -github.com/Azure/go-amqp v0.15.0/go.mod h1:9YJ3RhxRT1gquYnzpZO1vcYMMpAdJT+QEg6fwmw9Zlg= +github.com/Azure/go-amqp v0.17.5 h1:7Lsi9H9ijCAfqOaMiNmQ4c+GL9bdrpCjebNKhV/eQ+c= +github.com/Azure/go-amqp v0.17.5/go.mod h1:9YJ3RhxRT1gquYnzpZO1vcYMMpAdJT+QEg6fwmw9Zlg= github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU= github.com/BurntSushi/xgb v0.0.0-20160522181843-27f122750802/go.mod h1:IVnqGOEym/WlBOVXweHU+Q+/VP0lqqI8lqeDx9IjBqo= github.com/RoaringBitmap/roaring v0.4.23/go.mod h1:D0gp8kJQgE1A4LQ5wFLggQEyvDi06Mq5mKs52e1TwOo=