how to deal with confirm mode? about go-rabbitmq HOT 4 CLOSED

then i try other way, the code below, the process block forever:

conn, err := rabbitmq.NewConn("amqp://xxx:[email protected]:5672/")
if err != nil {
return err
}
args := rabbitmq.Table{
"x-delayed-type": "direct",
}
pub, err := rabbitmq.NewPublisher(conn,
rabbitmq.WithPublisherOptionsExchangeKind("x-delayed-message"),
rabbitmq.WithPublisherOptionsExchangeDurable,
rabbitmq.WithPublisherOptionsExchangeName("panda.test.delay"),
rabbitmq.WithPublisherOptionsExchangeArgs(args),
)
defer pub.Close()
if err != nil {
return err
}

confirmRes := make(chan bool, 1)
pub.NotifyPublish(func(p rabbitmq.Confirmation) {
	confirmRes <- p.Ack
	close(confirmRes)
})

err = pub.PublishWithContext(context.Background(), []byte(`{"test":"a"}`), []string{"delay.queue"},
	rabbitmq.WithPublishOptionsContentType("application/json"),
	rabbitmq.WithPublishOptionsPersistentDelivery,
	rabbitmq.WithPublishOptionsExchange("panda.test.delay"),
	rabbitmq.WithPublishOptionsTimestamp(time.Now()),
)
if err != nil {
	return err
}
for k := range confirmRes {
	if !k {
		return errors.New("server confirm fail")
	}
}

i read the code, find pub.NotifyPublish can't ensure execute before pub.PublishWithContext, so block forever ?

from go-rabbitmq.

I have the same problem as described in the description of this issue. When I step through the code, I get to "github.com/rabbitmq/amqp091-go", channel.go:1439 which has ch.confirming equal to false which is why the DeferredConfirmation we get is false.

It looks like the code on publish.go:334 never runs, and therefore never sets the channel into Confirm Mode. @michale-developer did you ever solve this problem?

@wagslane please could you assist?

from go-rabbitmq.

I have the same problem as described in the description of this issue. When I step through the code, I get to "github.com/rabbitmq/amqp091-go", channel.go:1439 which has ch.confirming equal to false which is why the DeferredConfirmation we get is false.

It looks like the code on publish.go:334 never runs, and therefore never sets the channel into Confirm Mode. @michale-developer did you ever solve this problem?

@wagslane please could you assist?

I found a workaround. This library ONLY sets the channel into Confirm Mode under two conditions:

1. If it disconnects and needs to be reconnected (publish.go:117)
2. If a NotifyPublish handler is used. (publish.go:308)
   (because those are the only two times startPublishHandler is called which invokes publisher.chanManager.ConfirmSafe(false))

So, a workaround is to create a blank NotifyPublish handler even if you don't need one. e.g:

publisher.NotifyPublish(func(p rabbitmq.Confirmation) {
	// DO NOTHING! - THIS IS JUST HERE TO MAKE SURE THE CHANNEL IS PUT INTO CONFIRM MODE
})

from go-rabbitmq.

Fixed in the latest! You should just need to NotifyPublish OR set the publisher to confirm mode

from go-rabbitmq.