block on add/delete in replication server instead of in vhost publish

src/lavinmq/replication/server.cr

@@ -51,11 +51,13 @@ module LavinMQ
 
       def append(path : String, obj)
         Log.debug { "appending #{obj} to #{path}" }
+        wait_for_max_lag
         each_follower &.append(path, obj)
       end
 
       def delete_file(path : String)
         @files.delete(path)
+        wait_for_max_lag
         each_follower &.delete(path)
       end
 

src/lavinmq/vhost.cr

@@ -113,8 +113,6 @@ module LavinMQ
       find_all_queues(ex, msg.routing_key, headers, visited, found_queues)
       headers.delete("BCC") if headers
 
-      @replicator.wait_for_max_lag
-
       if found_queues.empty?
         ex.unroutable_count += 1
         return false