github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 22:57:16 -04:00
Code Issues Projects Releases Packages Wiki Activity

review comments

Browse source 
Fixes #6498
This commit is contained in:
Pier-Hugues Pellerin 2017-01-13 10:41:12 -05:00
parent 8e57042e25
commit fdc4c15e46
1 changed files with 5 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

9
logstash-core/lib/logstash/queue_factory.rb
View file

@ -15,18 +15,19 @@ module LogStash
checkpoint_max_writes = settings.get("queue.checkpoint.writes") checkpoint_max_writes = settings.get("queue.checkpoint.writes")
checkpoint_max_interval = settings.get("queue.checkpoint.interval") checkpoint_max_interval = settings.get("queue.checkpoint.interval")
if queue_type == "memory_acked" case queue_type
when "memory_acked"
# memory_acked is used in tests/specs # memory_acked is used in tests/specs
LogStash::Util::WrappedAckedQueue.create_memory_based("", queue_page_capacity, queue_max_events, queue_max_bytes) LogStash::Util::WrappedAckedQueue.create_memory_based("", queue_page_capacity, queue_max_events, queue_max_bytes)
elsif queue_type == "memory" when "memory"
# memory is the legacy and default setting # memory is the legacy and default setting
LogStash::Util::WrappedSynchronousQueue.new LogStash::Util::WrappedSynchronousQueue.new
elsif queue_type == "persisted" when "persisted"
# persisted is the disk based acked queue # persisted is the disk based acked queue
queue_path = settings.get("path.queue") queue_path = settings.get("path.queue")
LogStash::Util::WrappedAckedQueue.create_file_based(queue_path, queue_page_capacity, queue_max_events, checkpoint_max_writes, checkpoint_max_acks, checkpoint_max_interval, queue_max_bytes) LogStash::Util::WrappedAckedQueue.create_file_based(queue_path, queue_page_capacity, queue_max_events, checkpoint_max_writes, checkpoint_max_acks, checkpoint_max_interval, queue_max_bytes)
else else
raise ConfigurationError, "invalid queue.type setting" raise ConfigurationError, "Invalid setting `#{queue_type}` for `queue.type`, supported types are: 'memory_acked', 'memory', 'persisted'"
end end
end end
end end