Implement ConnectionListener interface.

- Handle concurrency.