aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorKonstantin Lebedev <9497591+kmlebedev@users.noreply.github.com>2022-07-06 10:05:29 +0500
committerKonstantin Lebedev <9497591+kmlebedev@users.noreply.github.com>2022-07-06 10:05:29 +0500
commit785223e587fea23508f5bd304749b45a0e56430b (patch)
tree613cb3c7645e3d612ccb4266b1dfb2d8bef89086
parent57975b93ff463e71b20aed8feb1e669ee0f72780 (diff)
downloadseaweedfs-785223e587fea23508f5bd304749b45a0e56430b.tar.xz
seaweedfs-785223e587fea23508f5bd304749b45a0e56430b.zip
rabbitpubsub enable durable
-rw-r--r--weed/replication/sub/notification_gocdk_pub_sub.go8
1 files changed, 4 insertions, 4 deletions
diff --git a/weed/replication/sub/notification_gocdk_pub_sub.go b/weed/replication/sub/notification_gocdk_pub_sub.go
index cb690e3ce..ad4031190 100644
--- a/weed/replication/sub/notification_gocdk_pub_sub.go
+++ b/weed/replication/sub/notification_gocdk_pub_sub.go
@@ -46,17 +46,17 @@ func QueueDeclareAndBind(conn *amqp.Connection, exchangeUrl string, queueUrl str
}
defer ch.Close()
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)
return err
}
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)
return err
}
if _, err := ch.QueueDeclare(
- queueName, false, false, false, false,
+ queueName, true, false, false, false,
amqp.Table{"x-dead-letter-exchange": exchangeNameDLX}); err != nil {
glog.Error(err)
return err
@@ -66,7 +66,7 @@ func QueueDeclareAndBind(conn *amqp.Connection, exchangeUrl string, queueUrl str
return err
}
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 {
glog.Error(err)
return err