Skip to content

Instantly share code, notes, and snippets.

View vigneshwaranr's full-sized avatar

Vigneshwaran Raveendran vigneshwaranr

View GitHub Profile
def send(message: Message): Future[Boolean] = {
if (isValid(message)) {
producer.send(message).recover({case _ => false})
} else {
Future(false) // this is not good
}
}
def send(message: Message): Future[Boolean] = {
if (isValid(message)) {
producer.send(message).recover({case _ => false})
} else {
Future.successful(false) // fixed :)
}
}