nonBlockingConnectionFactory

fun nonBlockingConnectionFactory(threadNumber: Int = 1, f: ConnectionFactory.() -> Unit): ConnectionFactory