logstash/bin/cpdump
2017-07-18 16:21:09 -04:00

11 lines
377 B
Ruby
Executable file

#!/usr/bin/env bin/ruby
require_relative "../lib/bootstrap/environment"
LogStash::Bundler.setup!({:without => [:build, :development]})
require "logstash-core"
require "logstash/environment"
require "logstash/settings"
io = Java::OrgLogstashAckedqueueIo::FileCheckpointIO.new(LogStash::SETTINGS.get_value("path.queue"))
cp = io.read(ARGV[0])
puts("checkpoint #{cp.toString}")