diff options
| author | Chris Lu <chrislusf@users.noreply.github.com> | 2022-07-06 00:19:49 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-07-06 00:19:49 -0700 |
| commit | bfea7008f36d35ee253f75068066d8aab77d04b2 (patch) | |
| tree | 613cb3c7645e3d612ccb4266b1dfb2d8bef89086 | |
| parent | 57975b93ff463e71b20aed8feb1e669ee0f72780 (diff) | |
| parent | 785223e587fea23508f5bd304749b45a0e56430b (diff) | |
| download | seaweedfs-bfea7008f36d35ee253f75068066d8aab77d04b2.tar.xz seaweedfs-bfea7008f36d35ee253f75068066d8aab77d04b2.zip | |
Merge pull request #3277 from kmlebedev/rabbitry_enable_durable
| -rw-r--r-- | weed/replication/sub/notification_gocdk_pub_sub.go | 8 |
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 |