cleanup

src/lavinmq/http/controller/nodes.cr

@@ -77,6 +77,7 @@ module LavinMQ
           run_queue:          0,
           sockets_used:       @amqp_server.vhosts.sum { |_, v| v.connections.size },
           followers:          @amqp_server.followers,
+          min_followers:      @amqp_server.min_followers
         }
       end
 
@@ -106,6 +107,12 @@ module LavinMQ
           end
           context
         end
+
+        put "/api/nodes/min_followers" do |context, params|
+          puts "min followers endpoint trigger"
+
+        end
+
       end
 
       APPLICATIONS = [{

src/lavinmq/replication/server.cr

@@ -24,7 +24,7 @@ module LavinMQ
       @followers = Array(Follower).new
       @password : String
       @files = Hash(String, MFile?).new
-      @min_followers = 5_i64
+      @min_followers = 0_i64
 
       def initialize
         @password = password

src/lavinmq/vhost.cr

@@ -113,8 +113,6 @@ 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?