Logging Service Activator -- Real Time Logging Project

LoggingServiceActivator.groovy

@Service
class LoggingServiceActivator {
    @Autowired
    private LoggingService loggingService


    /** Spring Integration makes getting at the headers and payload really, really simple **/
    public void log(@Headers Map<String, Object> headers, @Payload LoggingEvent loggingEvent) {
        LogMessageCommand command = new LogMessageCommand(
                level: loggingEvent.level.toString(),
                application: headers."application.name",
                hostname: headers.hostname,
                ipAddress: headers."ip-address",
                threadName: loggingEvent.threadName,
                message: loggingEvent.renderedMessage
        )
        loggingService.log(command)
    }
}

LogMessageCommand.groovy

class LogMessageCommand {
    String level
    String threadName
    String application
    String message
    String hostname
    String ipAddress
    LocalDateTime messageTime = new LocalDateTime() // this is joda-time
}