diff --git a/logstash-core/src/main/java/org/logstash/RubyUtil.java b/logstash-core/src/main/java/org/logstash/RubyUtil.java
index f46fb02b2..5f6a5b3f1 100644
--- a/logstash-core/src/main/java/org/logstash/RubyUtil.java
+++ b/logstash-core/src/main/java/org/logstash/RubyUtil.java
@@ -1,6 +1,8 @@
 package org.logstash;
 
+import org.jruby.NativeException;
 import org.jruby.Ruby;
+import org.jruby.exceptions.RaiseException;
 
 /**
  * Utilities around interaction with the {@link Ruby} runtime.
@@ -30,4 +32,16 @@ public final class RubyUtil {
         ruby.getOrCreateModule(LS_MODULE_NAME);
         return ruby;
     }
+
+    /**
+     * Wraps a Java exception in a JRuby IOError NativeException.
+     * This preserves the Java stacktrace and bubble up as a Ruby IOError
+     * @param runtime the Ruby runtime context
+     * @param e the Java exception to wrap
+     * @return RaiseException the wrapped IOError
+     */
+    public static RaiseException newRubyIOError(Ruby runtime, Throwable e) {
+        // will preserve Java stacktrace & bubble up as a Ruby IOError
+        return new RaiseException(e, new NativeException(runtime, runtime.getIOError(), e));
+    }
 }
diff --git a/logstash-core/src/main/java/org/logstash/ackedqueue/ext/JrubyAckedBatchExtLibrary.java b/logstash-core/src/main/java/org/logstash/ackedqueue/ext/JrubyAckedBatchExtLibrary.java
index 5dae600e0..e22630a2c 100644
--- a/logstash-core/src/main/java/org/logstash/ackedqueue/ext/JrubyAckedBatchExtLibrary.java
+++ b/logstash-core/src/main/java/org/logstash/ackedqueue/ext/JrubyAckedBatchExtLibrary.java
@@ -17,7 +17,6 @@ import org.logstash.ackedqueue.Batch;
 import org.logstash.Event;
 import org.logstash.ackedqueue.Queueable;
 import org.logstash.ext.JrubyEventExtLibrary;
-
 import java.io.IOException;
 
 public final class JrubyAckedBatchExtLibrary implements Library {
@@ -84,7 +83,7 @@ public final class JrubyAckedBatchExtLibrary implements Library {
             try {
                 this.batch.close();
             } catch (IOException e) {
-                throw context.runtime.newIOErrorFromException(e);
+                throw RubyUtil.newRubyIOError(context.runtime, e);
             }
 
             return context.nil;
diff --git a/logstash-core/src/main/java/org/logstash/ackedqueue/ext/JrubyAckedQueueExtLibrary.java b/logstash-core/src/main/java/org/logstash/ackedqueue/ext/JrubyAckedQueueExtLibrary.java
index 1c4f40ece..d06851912 100644
--- a/logstash-core/src/main/java/org/logstash/ackedqueue/ext/JrubyAckedQueueExtLibrary.java
+++ b/logstash-core/src/main/java/org/logstash/ackedqueue/ext/JrubyAckedQueueExtLibrary.java
@@ -128,7 +128,7 @@ public final class JrubyAckedQueueExtLibrary implements Library {
             try {
                 this.queue.open();
             } catch (IOException e) {
-                throw context.runtime.newIOErrorFromException(e);
+                throw RubyUtil.newRubyIOError(context.runtime, e);
             }
 
             return context.nil;
@@ -145,7 +145,7 @@ public final class JrubyAckedQueueExtLibrary implements Library {
             try {
                 seqNum = this.queue.write(((JrubyEventExtLibrary.RubyEvent) event).getEvent());
             } catch (IOException e) {
-                throw context.runtime.newIOErrorFromException(e);
+                throw RubyUtil.newRubyIOError(context.runtime, e);
             }
 
             return context.runtime.newFixnum(seqNum);
@@ -159,7 +159,7 @@ public final class JrubyAckedQueueExtLibrary implements Library {
             try {
                 b = this.queue.readBatch(RubyFixnum.num2int(limit), RubyFixnum.num2int(timeout));
             } catch (IOException e) {
-                throw context.runtime.newIOErrorFromException(e);
+                throw RubyUtil.newRubyIOError(context.runtime, e);
             }
 
             // TODO: return proper Batch object
@@ -184,7 +184,7 @@ public final class JrubyAckedQueueExtLibrary implements Library {
             try {
                 this.queue.close();
             } catch (IOException e) {
-                throw context.runtime.newIOErrorFromException(e);
+                throw RubyUtil.newRubyIOError(context.runtime, e);
             }
 
             return context.nil;
diff --git a/logstash-core/src/main/java/org/logstash/ackedqueue/ext/JrubyAckedQueueMemoryExtLibrary.java b/logstash-core/src/main/java/org/logstash/ackedqueue/ext/JrubyAckedQueueMemoryExtLibrary.java
index 2f905f496..bef395938 100644
--- a/logstash-core/src/main/java/org/logstash/ackedqueue/ext/JrubyAckedQueueMemoryExtLibrary.java
+++ b/logstash-core/src/main/java/org/logstash/ackedqueue/ext/JrubyAckedQueueMemoryExtLibrary.java
@@ -126,7 +126,7 @@ public final class JrubyAckedQueueMemoryExtLibrary implements Library {
                 this.queue.getCheckpointIO().purge();
                 this.queue.open();
             } catch (IOException e) {
-                throw context.runtime.newIOErrorFromException(e);
+                throw RubyUtil.newRubyIOError(context.runtime, e);
             }
 
             return context.nil;
@@ -143,7 +143,7 @@ public final class JrubyAckedQueueMemoryExtLibrary implements Library {
             try {
                 seqNum = this.queue.write(((JrubyEventExtLibrary.RubyEvent) event).getEvent());
             } catch (IOException e) {
-                throw context.runtime.newIOErrorFromException(e);
+                throw RubyUtil.newRubyIOError(context.runtime, e);
             }
 
             return context.runtime.newFixnum(seqNum);
@@ -157,7 +157,7 @@ public final class JrubyAckedQueueMemoryExtLibrary implements Library {
             try {
                 b = this.queue.readBatch(RubyFixnum.num2int(limit), RubyFixnum.num2int(timeout));
             } catch (IOException e) {
-                throw context.runtime.newIOErrorFromException(e);
+                throw RubyUtil.newRubyIOError(context.runtime, e);
             }
 
             // TODO: return proper Batch object
@@ -182,7 +182,7 @@ public final class JrubyAckedQueueMemoryExtLibrary implements Library {
             try {
                 this.queue.close();
             } catch (IOException e) {
-                throw context.runtime.newIOErrorFromException(e);
+                throw RubyUtil.newRubyIOError(context.runtime, e);
             }
 
             return context.nil;