class JmsReplyingProducer extends Actor with Producer {
  def endpointUri = "jms:queue:test"
  override def oneway = true
  override def receiveAfterProduce = {
    case message: Message => self.reply("done")
    case failure: Failure => self.reply("message could not be added to queue: %s" format failure.cause.getMessage)
  }
}