Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- override def log(messages: Seq[LogEntry]): Future[ResultCode] = {
- _pool {
- var resultCode: ResultCode = ResultCode.TryLater
- log.debug("Received {} messages.", messages.size)
- if (messages.isEmpty) resultCode = ResultCode.Ok
- try {
- _jmsTemplate.send(_destination, new MessageCreator {
- def createMessage(session: Session): Message = {
- val message: Message = session.createObjectMessage(messages.toArray)
- message.setStringProperty(Constants.BATCH_ID, UUID.randomUUID.toString)
- return message
- }
- })
- log.debug("Messages sent successfully...")
- resultCode = ResultCode.Ok
- }
- return resultCode
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement