--- JDBC4MysqlPooledConnection.java 2011-09-19 10:40:20.000000000 +0200 +++ JDBC4MysqlPooledConnection.java 2011-09-19 10:45:56.000000000 +0200 @@ -75,8 +74,8 @@ *
* @since 1.6 */ - public void addStatementEventListener(StatementEventListener listener) { - synchronized (this.statementEventListeners) { + public synchronized void addStatementEventListener(StatementEventListener listener) { + if (this.statementEventListeners != null) { this.statementEventListeners.put(listener, listener); } } @@ -92,14 +91,14 @@ *
* @since 1.6 */ - public void removeStatementEventListener(StatementEventListener listener) { - synchronized (this.statementEventListeners) { + public synchronized void removeStatementEventListener(StatementEventListener listener) { + if (this.statementEventListeners != null) { this.statementEventListeners.remove(listener); } } - void fireStatementEvent(StatementEvent event) throws SQLException { - synchronized (this.statementEventListeners) { + synchronized void fireStatementEvent(StatementEvent event) throws SQLException { + if (this.statementEventListeners != null) { for (StatementEventListener listener : this.statementEventListeners.keySet()) { listener.statementClosed(event); }