extern/zrok
1
1
Fork 0
mirror of https://github.com/openziti/zrok.git synced 2025-01-22 05:48:46 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix amqp

Browse Source
This commit is contained in:
Cam Otts 2023-05-22 15:23:55 -05:00
parent de02cea5f3
commit 6a572c9977
No known key found for this signature in database
GPG Key ID: 367B7C7EBD84A8BD
3 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
controller/metrics/agent.go
View File

@ -58,7 +58,9 @@ func (a *Agent) Start() error {
}
}
if shouldAck {
event.Ack()
if err := event.Ack(); err != nil {
logrus.Error("unable to Ack message", err)
}
}
} else {
logrus.Error(err)

2
controller/metrics/amqpSource.go
View File

@ -73,7 +73,7 @@ func (s *amqpSource) Start(events chan ZitiEventMsg) (join chan struct{}, err er
for event := range s.msgs {
events <- &ZitiEventAMQP{
data: ZitiEventJson(event.Body),
msg: &event,
msg: event,
}
}
close(s.join)

6
controller/metrics/model.go
View File

@ -5,7 +5,6 @@ import (
"time"
"github.com/openziti/zrok/util"
"github.com/pkg/errors"
amqp "github.com/rabbitmq/amqp091-go"
)
@ -58,7 +57,7 @@ func (e *ZitiEventJsonMsg) Ack() error {
type ZitiEventAMQP struct {
data ZitiEventJson
msg *amqp.Delivery
msg amqp.Delivery
}
func (e *ZitiEventAMQP) Data() ZitiEventJson {
@ -66,9 +65,6 @@ func (e *ZitiEventAMQP) Data() ZitiEventJson {
}
func (e *ZitiEventAMQP) Ack() error {
if e.msg != nil {
return errors.New("Nil delivery message")
}
return e.msg.Ack(false)
}