You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Hi, thanks for your great work on AMQP implementation!
I having a problem on detect when channel enter in flow mode using RabbitMQ 3.8.15, after the channel creation i start a goroutine that check if some messages are sent from the server:
// Flow is sent to publisher channel when the Broker can't accept new messages.notifyFlow:=channel.NotifyFlow(make(chanbool))
gofunc() {
for {
select {
caseflow, ok:=<-notifyFlow:
{
if!ok {
return
}
ifflow {
// On flow true resume all publishingpublisher.lock.Unlock()
} else {
// On flow false stop all publishingpublisher.lock.Lock()
}
}
case<-publisher.ctx.Done():
{
return
}
}
}
}()
The channel isn't in confirm or transaction mode.
On the same channel i start publishing in loop 1 millon messages, the connection on broker side are in flow mode:
bash-5.1# rabbitmqctl list_connections
Listing connections ...
user peer_host peer_port state
guest 172.20.0.1 62810 flow
bash-5.1# rabbitmqctl list_channels
Listing channels ...
pid user consumer_count messages_unacknowledged
<[email protected]> guest 0 0
bash-5.1#
but no notification is returned from the channel passed to NotifyFlow, any ideas?
The text was updated successfully, but these errors were encountered:
Hi, thanks for your great work on AMQP implementation!
I having a problem on detect when channel enter in flow mode using RabbitMQ 3.8.15, after the channel creation i start a goroutine that check if some messages are sent from the server:
The channel isn't in confirm or transaction mode.
On the same channel i start publishing in loop 1 millon messages, the connection on broker side are in flow mode:
but no notification is returned from the channel passed to NotifyFlow, any ideas?
The text was updated successfully, but these errors were encountered: