class Dbutil {

    companion object : KLogging()

    /**
     * DSL for extending the SQL2O for making a basic select Query and returning MutableList<T>
     */
    public inline fun <reified T : Any> Connection.selectQuery(sqlString: String): MutableList<T>? {

        try {
            val connection: Connection = sql2o.open()
            val results = connection.createQuery(sqlString).executeAndFetch(T::class.java)
            return results
        } catch (e: Exception) {
            println(e.toString())
            return null
        }
    }


}

fun selectQuerytest() {
        var con: Connection = sql2o.open()
        var vidaudList: MutableList<vidaud>? = con.selectQuery<vidaud>("select source, timestamp from video_audio limit 100")

    }

DbUtil

with (Dbutil()) {
    con.selectQuery
}

this@selectQuery

this@Dbutil

con

with(Dbutil()) {}

fun Channel.consume(
	queue: String = "",
	autoAck: Boolean = true,
	onMessage: (consumerTag: String, envelope: Envelope, properties: BasicProperties, json: String) -> Unit
){
	this.basicConsume(queue, autoAck, object : DefaultConsumer(this) {
		override fun handleDelivery(consumerTag: String?, envelope: Envelope?, properties: AMQP.BasicProperties?, body: ByteArray?) {
			onMessage(
				consumerTag ?: "",
				envelope ?: Envelope(0, false, "", ""),
				properties ?: AMQP.BasicProperties(),
				if (body != null) String(body) else "")
		}
	});
}

channel.consume(queue = "api", onMessage = (a: String, b: Envelope, c: BasicProperties, d: String){

		})

Unresolved Reference

channel.consume(queue = "api", onMessage = { a: String, b: Envelope, c: BasicProperties, d: String ->

})

{ a, b, c, d ->

val func: (consumerTag: String, envelope: Any, properties: Any, json: String) -> Unit = { str, env: Any, prop, json: String ->  }