restart replication if RabbitMQ connection closed

https://github.com/google/go-cloud/issues/2958

2 files changed, 28 insertions, 0 deletions

diff --git a/docker/compose/notification.toml b/docker/compose/notification.toml
new file mode 100644
index 000000000..dcd5f2c6f
--- /dev/null
+++ b/docker/compose/notification.toml
@@ -0,0 +1,17 @@
+[notification.log]
+# this is only for debugging perpose and does not work with "weed filer.replicate"
+enabled = false
+
+
+[notification.gocdk_pub_sub]
+# The Go Cloud Development Kit (https://gocloud.dev).
+# PubSub API (https://godoc.org/gocloud.dev/pubsub).
+# Supports AWS SNS/SQS, Azure Service Bus, Google PubSub, NATS and RabbitMQ.
+enabled = true
+# This URL will Dial the RabbitMQ server at the URL in the environment
+# variable RABBIT_SERVER_URL and open the exchange "myexchange".
+# The exchange must have already been created by some other means, like
+# the RabbitMQ management plugin. Сreate myexchange of type fanout and myqueue then
+# create binding myexchange => myqueue
+topic_url = "rabbit://swexchange"
+sub_url = "rabbit://swqueue"
\ No newline at end of file
diff --git a/docker/compose/replication.toml b/docker/compose/replication.toml
new file mode 100644
index 000000000..833bb1692
--- /dev/null
+++ b/docker/compose/replication.toml
@@ -0,0 +1,11 @@
+[source.filer]
+enabled = true
+grpcAddress = "filer:18888"
+# all files under this directory tree are replicated.
+# this is not a directory on your hard drive, but on your filer.
+# i.e., all files with this "prefix" are sent to notification message queue.
+directory = "/buckets"
+
+[sink.local_incremental]
+enabled = true
+directory = "/data"
\ No newline at end of file