Уточните, пожалуйста, воспроизводится ли ошибка в стандартном примере Two-way Streaming?
Если не воспроизводится, то попробуйте модифицировать код этого примера таким образом, чтобы проблема воспроизводилась, и пришлите этот код нам.
Часть кода, которую вы приводите выше мы проверили. На наших...