Spring Integration Resources Configuration -- Real Time Logging

resources.groovy

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") {
      integration."service-activator"(method: "log", ref:"logServiceActivator")
  }

  /* Attach the JMS channel adapter from our ActiveMQTopic "log.*" to our Spring Integration channel, "logChannel" */
  jms."message-driven-channel-adapter"(id: 'logsIn', destination: 'logMessageDestination', channel: 'logChannel')
  ...
}