Cómo retrasar el arranque de frijoles primavera?

Question

Tiene una aplicación de primavera (en realidad la aplicación Grails) que ejecuta el servidor apache-activemq como Spring Bean y un par de rutas apache-camel. Uso de la aplicación Hibernate para trabajar con la base de datos. El problema es simple Activemq + Camel inicia BEFORE grails inyecta métodos especiales en hibernar objetos de dominio (en realidad, guardar/actualizar métodos, etc.). Por lo tanto, si activemq ya tiene algunos datos al inicio, camel inicia el procesamiento de los mensajes sin que se hayan inyectado los métodos DAO de grails. Esto falla con grails.lang.MissingMethodException. Debe retrasar el inicio de activemq/camel antes de que Grails inyecte métodos especiales en objetos de dominio.

Answer 1

se puede mover managment MQ en un plugin? Aumentaría la modularidad y si declara en plugin-descriptor

def loadAfter = ['hibernate'] 

debe tener el comportamiento deseado. Funciona para JBPM plugin

Answer 2

Si todos estos se definen como grano de primavera, se puede utilizar

<bean id="activeMqBean" depends-on="anotherBean" /> 

Esto se asegurará de anotherBean se inicializa antes activeMqBean

Answer 3

No estoy seguro en su caso, pero la carga diferida también puede ayudar, p.

<bean id="lazybean" class="com.xxx.YourBean" lazy-init="true"> 

Un grano inicializado perezosamente-indica al contenedor IoC para crear instancia del bean cuando se solicita primero. Esto puede ayudarlo a retrasar la carga de los granos que desee.

Answer 4

Sé que esta pregunta es bastante antigua, pero ahora estoy enfrentando el mismo problema en el año 2015, y este hilo no ofrece una solución para mí.

Inventé un procesador personalizado que tiene un CountDownLatch, que cuento después de la inicialización de la aplicación. Entonces, los mensajes estarán inactivos hasta que la aplicación haya comenzado completamente y esté funcionando para mí.

/** 
* bootstrap latch processor 
*/ 
@Log4j 
class BootstrapLatchProcessor implements Processor { 
    private final CountDownLatch latch = new CountDownLatch(1) 

    @Override 
    void process(Exchange exchange) throws Exception { 

     if(latch.count > 0){ 
      log.info "waiting for bootstrapped @ ${exchange.fromEndpoint}" 
      latch.await() 
     } 

     exchange.out = exchange.in 
    } 

    /** 
     * mark the application as bootstrapped 
     */ 
    public void setBootstrapped(){ 
     latch.countDown() 
    } 
} 

luego usarlo como un grano en su aplicación y llame al método setBootstrapped en su Bootstrap.groovy

Luego, en su RouteBuilder se pone el procesador entre su punto final y de destino para todas las rutas que se pueden esperar los mensajes procedentes antes de que la aplicación haya comenzado:

from("activemq:a.in ").processRef('bootstrapProcessor').to("bean:handlerService?method=handle")