mirror/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-01-18 06:30:07 +08:00
Code Issues Packages Projects Releases Wiki Activity

rabbitpubsub enable durable

Browse Source
This commit is contained in:
Konstantin Lebedev 2022-07-06 10:05:29 +05:00
parent 57975b93ff
commit 785223e587
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
weed/replication/sub/notification_gocdk_pub_sub.go
View File

@ -46,17 +46,17 @@ func QueueDeclareAndBind(conn *amqp.Connection, exchangeUrl string, queueUrl str
} }
defer ch.Close() defer ch.Close()
if err := ch.ExchangeDeclare( if err := ch.ExchangeDeclare(
exchangeNameDLX, "fanout", false, false, false, false, nil); err != nil { exchangeNameDLX, "fanout", true, false, false, false, nil); err != nil {
glog.Error(err) glog.Error(err)
return err return err
} }
if err := ch.ExchangeDeclare( if err := ch.ExchangeDeclare(
exchangeName, "fanout", false, false, false, false, nil); err != nil { exchangeName, "fanout", true, false, false, false, nil); err != nil {
glog.Error(err) glog.Error(err)
return err return err
} }
if _, err := ch.QueueDeclare( if _, err := ch.QueueDeclare(
queueName, false, false, false, false, queueName, true, false, false, false,
amqp.Table{"x-dead-letter-exchange": exchangeNameDLX}); err != nil { amqp.Table{"x-dead-letter-exchange": exchangeNameDLX}); err != nil {
glog.Error(err) glog.Error(err)
return err return err
@ -66,7 +66,7 @@ func QueueDeclareAndBind(conn *amqp.Connection, exchangeUrl string, queueUrl str
return err return err
} }
if _, err := ch.QueueDeclare( if _, err := ch.QueueDeclare(
queueNameDLX, false, false, false, false, queueNameDLX, true, false, false, false,
amqp.Table{"x-dead-letter-exchange": exchangeName, "x-message-ttl": 600000}); err != nil { amqp.Table{"x-dead-letter-exchange": exchangeName, "x-message-ttl": 600000}); err != nil {
glog.Error(err) glog.Error(err)
return err return err