Advertisement
Guest User

Untitled

a guest
Oct 16th, 2014
170
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Scala 0.73 KB | None | 0 0
  1.   override def log(messages: Seq[LogEntry]): Future[ResultCode] = {
  2.     _pool {
  3.       var resultCode: ResultCode = ResultCode.TryLater
  4.  
  5.       log.debug("Received {} messages.", messages.size)
  6.  
  7.       if (messages.isEmpty) resultCode = ResultCode.Ok
  8.  
  9.       try {
  10.         _jmsTemplate.send(_destination, new MessageCreator {
  11.           def createMessage(session: Session): Message = {
  12.             val message: Message = session.createObjectMessage(messages.toArray)
  13.             message.setStringProperty(Constants.BATCH_ID, UUID.randomUUID.toString)
  14.             return message
  15.           }
  16.         })
  17.  
  18.         log.debug("Messages sent successfully...")
  19.  
  20.         resultCode = ResultCode.Ok
  21.  
  22.       }
  23.       return resultCode
  24.     }
  25.   }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement