reference correct class path

This commit is contained in:
Colin Surprenant 2017-07-14 16:34:24 -04:00
parent b6ebbb3eed
commit f3f24dc706

View file

@ -6,6 +6,6 @@ require "logstash-core"
require "logstash/environment"
require "logstash/settings"
io = Java::OrgLogstashCommonIo::FileCheckpointIO.new(LogStash::SETTINGS.get_value("path.queue"))
io = Java::OrgLogstashAckedqueueIo::FileCheckpointIO.new(LogStash::SETTINGS.get_value("path.queue"))
cp = io.read(ARGV[0])
puts("checkpoint #{cp.toString}")