TPS
/
turkmentv_sms_transmitter
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

durable queue

This commit is contained in:
merdan 2024-08-30 12:12:18 +05:00
parent 4a6dab9c52
commit 9614211fd5
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/mq/rabbitmq.go
View File

@ -64,7 +64,7 @@ func (r *rabbitMQ) Consume(ctx context.Context, messageHandler func(ctx context.
q, err := ch.QueueDeclare( q, err := ch.QueueDeclare(
r.queueName, // name r.queueName, // name
false, // durable true, // durable
false, // delete when unused false, // delete when unused
false, // exclusive false, // exclusive
false, // no-wait false, // no-wait