updateConsumeSockets

open override fun updateConsumeSockets(consumeSockets: List<Map<String, SocketManager>>)
open override val updateConsumeSockets: (List<ConsumeSocket>) -> Unit