diff --git a/src/de/diddiz/LogBlock/Consumer.java b/src/de/diddiz/LogBlock/Consumer.java
index 94abb69..672d540 100644
--- a/src/de/diddiz/LogBlock/Consumer.java
+++ b/src/de/diddiz/LogBlock/Consumer.java
@@ -322,7 +322,8 @@ public class Consumer extends TimerTask
 			try {
 				if (state != null)
 					state.close();
-				conn.close();
+				if (conn != null)
+					conn.close();
 			} catch (final SQLException ex) {
 				log.log(Level.SEVERE, "[LogBlock Consumer] SQL exception on close", ex);
 			}