Make worker queues durable (#312)

finleap-connect · Dec 9, 2022 · eb2d21f · eb2d21f
1 parent f100caf
commit eb2d21f
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/eventsourcing/messaging/bus_rabbitmq.go b/pkg/eventsourcing/messaging/bus_rabbitmq.go
@@ -191,6 +191,8 @@ func (b *rabbitEventBus) addHandler(ctx context.Context, handler evs.EventHandle
 	}
 	if workQueueName == "" {
 		options = append(options, rabbitmq.WithConsumeOptionsQueueExclusive)
+	} else {
+		options = append(options, rabbitmq.WithConsumeOptionsQueueDurable)
 	}
 
 	err := b.consumer.StartConsuming(