ActiveMQ integration with Spring context -- Real Time Logging Project

resources.groovy

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")
      }
  } 

  /* Create the caching connection factory */
  amqConnectionFactory(ActiveMQConnectionFactory) {
      brokerURL = "vm://localhost"
  }
  connectionFactory(CachingConnectionFactory) {
      targetConnectionFactory = ref('amqConnectionFactory')
      sessionCacheSize = 10
      cacheProducers = false
  }

  /* Construct the JMS topic destination */
  logMessageDestination(ActiveMQTopic, "log.*")
  ...
}