AMQP does't work

[moninCX]

Hi! I try to use amqp sample, and when I run, I got an compilation error:

github.com/cloudevents/sdk-go/protocol/amqp/v2
..\github.com\cloudevents\sdk-go\protocol\amqp\v2\message.go:125:23: not enough arguments in call to m.AMQP.Reject
have (*amqp.Error)
want (context.Context, *amqp.Error)
..\github.com\cloudevents\sdk-go\protocol\amqp\v2\message.go:130:22: not enough arguments in call to m.AMQP.Accept
have ()
want (context.Context)

When I open message.go - I see an error in the file. This file read-only and func Finish contain errors. It's normal?

[moninCX]

In the file message.go I added context.TODO() in Finish function:

func (m *Message) Finish(err error) error {
if err != nil {
return m.AMQP.Reject(context.TODO(),&amqp.Error{
Condition: condition,
Description: err.Error(),
})
}
return m.AMQP.Accept(context.TODO())
}

I'm not sure, that it correct solution, but error is gone.

[n3wscott]

It seems the API on the AMQP lib have changed. https://github.com/Azure/go-amqp/releases/tag/v0.13.6