Провайдеру соединения добавлен метод onClose(), с помощью которого консюмер сигнализирует о закрытии соединения. Убран отладочный вывод. Ращхединение работает с обеих сторон.
onClose()