Make firehose buffer size configurable

firehoseio · Dec 3, 2020 · 24e0449 · 24e0449
1 parent 3d7b0e7
commit 24e0449
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/firehose/server/message_buffer.rb b/lib/firehose/server/message_buffer.rb
@@ -5,7 +5,7 @@ module Server
     class MessageBuffer
       # Number of messages that Redis buffers for the client if its
       # connection drops, then reconnects.
-      DEFAULT_SIZE = 100
+      DEFAULT_SIZE = ENV.fetch("DEFAULT_BUFFER_SIZE", 100)
 
       def initialize(message_list, channel_sequence, consumer_sequence = nil)
         @message_list = message_list