diff --git a/src/de/diddiz/LogBlock/Consumer.java b/src/de/diddiz/LogBlock/Consumer.java
index 08da3bb..ca66870 100644
--- a/src/de/diddiz/LogBlock/Consumer.java
+++ b/src/de/diddiz/LogBlock/Consumer.java
@@ -105,6 +105,8 @@ public class Consumer implements Runnable
 			LogBlock.log.log(Level.SEVERE, "[LogBlock Consumer] SQL exception", ex);
 		} finally {
 			try {
+				if (conn != null)
+					conn.close();
 				if (state != null)
 					state.close();
 			} catch (SQLException ex) {