From 6e022542af7ec47187df857bfe1be4dd794406cd Mon Sep 17 00:00:00 2001 From: Michal Kuratczyk Date: Mon, 16 Dec 2024 14:17:15 +0100 Subject: [PATCH] Info->Debug for some AMQP outcomes --- pkg/amqp10/publisher.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/amqp10/publisher.go b/pkg/amqp10/publisher.go index 3e5f341..0e8492c 100644 --- a/pkg/amqp10/publisher.go +++ b/pkg/amqp10/publisher.go @@ -303,17 +303,17 @@ func (p *Amqp10Publisher) handleSent(receipt *amqp.SendReceipt, published time.T case *amqp.StateModified: // message must be modified and resent before it can be processed. // the values in stateType provide further context. - log.Info("server requires modifications to accept this message", "state", stateType) + log.Debug("server requires modifications to accept this message", "state", stateType) case *amqp.StateReceived: // see the fields in [StateReceived] for information on // how to handle this delivery state. - log.Info("message received but not processed by the broker", "state", stateType) + log.Debug("message received but not processed by the broker", "state", stateType) case *amqp.StateRejected: if stateType.Error != nil { log.Info("message rejected by the broker", "state", stateType.Error) } case *amqp.StateReleased: - log.Info("message released the broker", "state", stateType) + log.Debug("message released the broker", "state", stateType) } log.Debug("message receipt received", "outcome", state) }