Skip to content

Commit f319a03

Browse files
committed
Replicate limits.json
1 parent 49f935f commit f319a03

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/lavinmq/vhost.cr

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -93,6 +93,7 @@ module LavinMQ
9393
limits = JSON.parse(f)
9494
@max_queues = limits["max-queues"]?.try &.as_i?
9595
@max_connections = limits["max-connections"]?.try &.as_i?
96+
@replicator.try &.register_file(f)
9697
end
9798
rescue File::NotFoundError
9899
end
@@ -106,6 +107,7 @@ module LavinMQ
106107
end
107108
end
108109
end
110+
@replicator.try &.replace_file(File.join(@data_dir, "limits.json"))
109111
end
110112

111113
def inspect(io : IO)

0 commit comments

Comments
 (0)