danveloper

<!-- ... resources & jquery snipped for brevity ... -->
<atmosphere:resources/>
<r:script>
    $(document).ready(function() {
        var url = '${createLink(uri:ApplicationHolder.application.config.grails.atmosphere.mappingUri)}';
        $.atmosphere.subscribe(url, Logging.router, $.atmosphere.request = {transport:'websocket', fallbackTransport:'streaming'});
        ...
    });
</r:script>

danveloper

// Registering an application's logging instance either means creating a new mapping for it.
// If a mapping already exists, update its "latest update time" property.
private def registerApplicationInstance(String ipAddress, String hostname, String appName) {
    if (!applications[appName]) {
        applications[appName] = []
    }
    def existing = findApplicationObject(appName, ipAddress, hostname)
    if (!existing) {
        // Register the new application and create a unique mapping for it.
        applications[appName] << [ipAddress: ipAddress, hostname: hostname, lastUpdateTime: new LocalDateTime()]

danveloper

grails.atmosphere.mappingUri = '/atmosphere/logging'

danveloper

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

danveloper

beans = {
  ...
  /* Attach the message adapter */
  logServiceActivator(LoggingServiceActivator)

  /* Create the log channel, for internal transport */
  integration.channel(id: "logChannel")

  /* Attach a chain to the log channel, this will delegate the message to the LoggingServiceActivator */
  integration.chain("input-channel": "logChannel") {

danveloper

dependencies {
  ...
  compile 'org.springframework.integration:spring-integration-core:2.2.0.RELEASE'
  compile 'org.springframework.integration:spring-integration-jms:2.2.0.RELEASE'
  compile 'org.springframework.integration:spring-integration-stream:2.2.0.RELEASE'
  ...
}

danveloper

beans = {
  ...
  xmlns amq:"http://activemq.apache.org/schema/core"

  /* Establish the broker */
  amq.broker(useJmx: false, persistent: false) {
      amq.transportConnectors() {
          amq.transportConnector(uri: "tcp://localhost:61616")
      }
  } 

danveloper

dependencies {
 ...
 compile 'org.apache.activemq:activemq-core:5.7.0'
 // (this is necessary for namespace support)
 compile 'org.apache.xbean:xbean-spring:3.12'
 ...
}

danveloper

// If you prefer Gradle
compile 'com.danveloper.log4j:enhanced-log4j-appender:0.1-SNAPSHOT'

danveloper

log4j.rootLogger=INFO, stdout, jms

## Be sure that ActiveMQ messages are not logged to 'jms' appender
log4j.logger.org.apache.activemq=INFO, stdout

log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%d %-5p %c - %m%n

## Configure 'jms' appender. You'll also need jndi.properties file in order to make it work