gistfile1.scala

import java.util.concurrent.BlockingQueue
import collection.JavaConversions

object Drainer {

  def drain[T](queue: BlockingQueue[T], max: Option[Int] = None) : Seq[T] = {
    val arrayList = new java.util.ArrayList[T]
    queue.drainTo(arrayList, max.getOrElse(queue.size()))
    JavaConversions.JListWrapper(arrayList)
  }

}