Adding a delay option to the send method. This allows a message to re…

…main invisable for some time ( max of 15 minutes ), which is helpful inlots of use cases

build.sbt

@@ -2,7 +2,7 @@ organization := "com.kifi"
 
 name := "franz"
 
-version := "0.3.11"
+version := "0.3.12-SNAPSHOT"
 
 crossScalaVersions := Seq("2.10.4", "2.11.5")
 

src/main/scala/com/kifi/franz/FakeSQSQueue.scala

@@ -17,7 +17,7 @@ trait FakeSQSQueue[T] extends SQSQueue[T] {
 
   override def initQueueUrl(): String = ""
 
-  override def send(msg: T, messageAttributes: Option[Map[String,String]]): Future[MessageId] = Future.successful(MessageId(""))
+  override def send(msg: T, messageAttributes: Option[Map[String,String]], delay: Option[Int]): Future[MessageId] = Future.successful(MessageId(""))
 
   override protected def nextBatchRequestWithLock(maxBatchSize: Int, lockTimeout: FiniteDuration): Future[Seq[SQSMessage[T]]] = Future.successful(Seq.empty)
 

src/main/scala/com/kifi/franz/SQSQueue.scala

@@ -61,11 +61,17 @@ trait SQSQueue[T]{
     send (msg, None)
   }
 
-  def send(msg: T, messageAttributes: Option[Map[String, String]] = None): Future[MessageId] = {
+  def send(msg: T, delay:Int): Future[MessageId] = {
+    send (msg, None, Some(delay))
+  }
+
+  def send(msg: T, messageAttributes: Option[Map[String, String]] = None, delay:Option[Int] = None): Future[MessageId] = {
     val request = new SendMessageRequest
     request.setMessageBody(msg)
     request.setQueueUrl(queueUrl)
-
+    delay.map{ d =>
+      request.setDelaySeconds(d)
+    }
     // foreach on an Option unfolds Some, and skips if None
     messageAttributes.foreach { ma =>
       ma.foreach { case (k,v) =>