diff --git a/bin/cpdump b/bin/cpdump
index 5bbca5122..dd5f09b5c 100755
--- a/bin/cpdump
+++ b/bin/cpdump
@@ -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}")