server settings for replication

cloudamqp · Jul 12, 2023 · 5071009 · 5071009
1 parent debbf03
commit 5071009
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/src/lavinmq/replication/server.cr b/src/lavinmq/replication/server.cr
@@ -24,6 +24,7 @@ module LavinMQ
       @followers = Array(Follower).new
       @password : String
       @files = Hash(String, MFile?).new
+      @min_followers = 5_i64
 
       def initialize
         @password = password
@@ -98,6 +99,12 @@ module LavinMQ
         end
       end
 
+      def min_followers : Int64
+        @lock.synchronize do
+          @min_followers.dup # for thread safety
+        end
+      end
+
       private def password : String
         path = File.join(Config.instance.data_dir, ".replication_secret")
         begin

diff --git a/src/lavinmq/vhost.cr b/src/lavinmq/vhost.cr
@@ -113,6 +113,9 @@ module LavinMQ
       headers = properties.headers
       find_all_queues(ex, msg.routing_key, headers, visited, found_queues)
       headers.try(&.delete("BCC"))
+      puts @replicator.min_followers
+      puts @replicator.followers.size
+      return false if @replicator.followers.size < @replicator.min_followers
       # @log.debug { "publish queues#found=#{found_queues.size}" }
       if found_queues.empty?
         ex.unroutable_count += 1