abc.scala

func() = {
    var dataList = List[Array[Byte]]()
    breakable {
        for (i <- 0 until noItems) {
            val response: GetResponse = channel.basicGet(queueName, true)
            if (response != null) {
                dataList = response.getBody :: dataList
            }
            else {
                break()
            }
        }
    }
    dataList
}