NotifyPublish ReconnectCount - how is it intended to be used? about go-rabbitmq HOT 1 OPEN

func (chanManager *ChannelManager) GetNextPublishSeqNo() uint64 {
	return chanManager.channel.GetNextPublishSeqNo()
}

func (publisher *Publisher) GetNextPublishSeqNo() uint64 {
	publisher.disablePublishDueToBlockedMux.RLock()
	defer publisher.disablePublishDueToBlockedMux.RUnlock()
	return publisher.chanManager.GetNextPublishSeqNo()
}

	// Publisher func
	go func() {

		publisher.NotifyPublish(func(p rabbitmq.Confirmation) {
			publisher_confirms <- p
		})
		publisher.NotifyReturn(func(r rabbitmq.Return) {
			publisher_returns <- &r
		})

		// Initialise a delivery counter to keep track of the DeliveryTags assigned to the messages
		for msg := range messages {

			deliveryTag := messagestore.DeliveryTag(publisher.GetNextPublishSeqNo())
			err := publisher.PublishWithContext(
				context.Background(),
				msg.Body,
				[]string{msg.RoutingKey},

				rabbitmq.WithPublishOptionsExchange("ingress"),
				rabbitmq.WithPublishOptionsContentType(msg.ContentType),
				rabbitmq.WithPublishOptionsContentEncoding(msg.ContentEncoding),
				rabbitmq.WithPublishOptionsAppID(msg.AppId),
				rabbitmq.WithPublishOptionsPersistentDelivery,
			)
			if err != nil {
				logger.Errorf("error publishing message, %s", err)
				continue
			}

			store.AppendMessage(deliveryTag, msg)
		}
	}()

	// Confirms func
	go func() {

		for {
			select {
			case confirm := <-publisher_confirms:
				// Try to confirm
				if confirm.Ack {
					logger.Infof("Attempting to ack DeliveryTag: %d and ReconnectionCount: %d", confirm.DeliveryTag, confirm.ReconnectionCount)
					store.Ack(messagestore.DeliveryTag(confirm.DeliveryTag))
				} else {
					logger.Infof("Attempting to nack DeliveryTag: %d and ReconnectionCount: %d", confirm.DeliveryTag, confirm.ReconnectionCount)
					store.Nack(messagestore.DeliveryTag(confirm.DeliveryTag), true)
				}

			case <-publisher_returns:

			}
		}
	}()