Closed consumer connection as well.

This commit is contained in:
Robin Kupper
2011-04-11 11:11:25 +02:00
parent 76c8431f07
commit a2f05f4702

View File

@@ -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) {