Skip to content

Instantly share code, notes, and snippets.

Avatar

Marek Tuchalski ith

  • Bangkok, Thailand
View GitHub Profile
View keybase.md

Keybase proof

I hereby claim:

To claim this, I am signing this object:

View Consumer.scala
import java.io.IOException
import scala.collection.JavaConversions._
import scala.collection.mutable
import scala.concurrent.duration._
import scala.util.control.Exception._
import akka.actor.{ActorLogging, Cancellable, PoisonPill}
import com.google.inject.Inject
import com.rabbitmq.client.AMQP.BasicProperties