revert commit 1de4c18

cloudamqp · May 27, 2024 · cae4655 · cae4655
1 parent 136b743
commit cae4655
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 2 deletions.
diff --git a/spec/replication_spec.cr b/spec/replication_spec.cr
@@ -41,7 +41,6 @@ describe LavinMQ::Replication::Client do
       repli.follow("127.0.0.1", LavinMQ::Config.instance.replication_port)
       done.send nil
     end
-    wait_for { Server.followers.size == 1 }
     with_channel do |ch|
       q = ch.queue("repli")
       q.publish_confirm "hello world"

diff --git a/src/lavinmq/replication/server.cr b/src/lavinmq/replication/server.cr
@@ -54,7 +54,6 @@ module LavinMQ
       end
 
       def append(path : String, file : MFile, position : Int32, length : Int32)
-        return if @followers.empty?
         append path, FileRange.new(file, position, length)
       end