bugfix: idle publishers would terminate too early

rabbitmq · Nov 28, 2024 · afd4222 · afd4222
1 parent 72c7571
commit afd4222
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/pkg/amqp10_client/publisher.go b/pkg/amqp10_client/publisher.go
@@ -185,7 +185,7 @@ func (p *Amqp10Publisher) StartFullSpeed(ctx context.Context) {
 }
 
 func (p *Amqp10Publisher) StartIdle(ctx context.Context) {
-	_ = ctx.Done()
+	<-ctx.Done()
 }
 
 func (p *Amqp10Publisher) StartRateLimited(ctx context.Context) {

diff --git a/pkg/mqtt_client/publisher.go b/pkg/mqtt_client/publisher.go
@@ -57,7 +57,7 @@ func (p MqttPublisher) StartFullSpeed(ctx context.Context) {
 func (p MqttPublisher) StartIdle(ctx context.Context) {
 	log.Info("publisher started", "id", p.Id, "rate", "-", "destination", p.Topic)
 
-	_ = ctx.Done()
+	<-ctx.Done()
 }
 
 func (p MqttPublisher) StartRateLimited(ctx context.Context) {

diff --git a/pkg/mqtt_client/publisher_v5.go b/pkg/mqtt_client/publisher_v5.go
@@ -60,7 +60,7 @@ func (p Mqtt5Publisher) StartFullSpeed(ctx context.Context) {
 func (p Mqtt5Publisher) StartIdle(ctx context.Context) {
 	log.Info("publisher started", "id", p.Id, "rate", "-", "destination", p.Topic)
 
-	_ = ctx.Done()
+	<-ctx.Done()
 }
 
 func (p Mqtt5Publisher) StartRateLimited(ctx context.Context) {

diff --git a/pkg/stomp_client/publisher.go b/pkg/stomp_client/publisher.go
@@ -109,7 +109,7 @@ func (p *StompPublisher) StartFullSpeed(ctx context.Context) {
 func (p *StompPublisher) StartIdle(ctx context.Context) {
 	log.Info("publisher started", "id", p.Id, "rate", "-", "destination", p.Topic)
 
-	_ = ctx.Done()
+	<-ctx.Done()
 }
 
 func (p *StompPublisher) StartRateLimited(ctx context.Context) {