Làm thế nào để trì hoãn khởi động hạt đậu mùa xuân?

Question

Có ứng dụng mùa xuân (thực sự là ứng dụng grails) chạy máy chủ apache-activemq làm bean mùa xuân và vài tuyến apache-lạc đà. Ứng dụng sử dụng ngủ đông để làm việc với cơ sở dữ liệu. Vấn đề rất đơn giản. Activemq + Camel khởi động BEFORE grails tiêm các phương thức đặc biệt vào các đối tượng miền ngủ đông (thực sự là lưu/cập nhật các phương thức, vv). Vì vậy, nếu activemq đã có một số dữ liệu khi khởi động - lạc đà bắt đầu xử lý các thông điệp với các phương thức grails DAO được tiêm. Điều này không thành công với grails.lang.MissingMethodException. Phải trì hoãn khởi động activemq/camel trước khi Grails tiêm các phương thức đặc biệt vào các đối tượng miền.

Answer 1

bạn có thể di chuyển MQ managment vào một plugin? Nó sẽ tăng tính mô đun và nếu bạn khai báo trong plugin-descriptor

def loadAfter = ['hibernate'] 

bạn nên có hành vi mong muốn. Hoạt động cho JBPM plugin

Answer 2

Nếu tất cả chúng được định nghĩa là đậu mùa xuân, bạn có thể sử dụng

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

này sẽ đảm bảo anotherBean được khởi tạo trước khi activeMqBean

Answer 3

Tôi không chắc chắn trong trường hợp của bạn nhưng tải chậm cũng có thể giúp ví dụ:

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

Đậu lười được khởi tạo chỉ ra vùng chứa IoC để tạo cá thể đậu khi được yêu cầu lần đầu tiên. Điều này có thể giúp bạn trì hoãn việc tải đậu bạn muốn.

Answer 4

Tôi biết câu hỏi này là khá cũ, nhưng bây giờ tôi đang đối mặt với cùng một vấn đề trong năm 2015 - và chủ đề này không cung cấp một giải pháp cho tôi.

Tôi đã đưa ra một bean xử lý tùy chỉnh có một CountDownLatch, mà tôi đếm ngược sau khi khởi động ứng dụng. Vì vậy, các tin nhắn sẽ được nhàn rỗi cho đến khi ứng dụng đã bắt đầu đầy đủ và nó làm việc cho tôi.

/** 
* 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() 
    } 
} 

Sau đó, sử dụng nó như một bean trong ứng dụng của bạn và gọi phương thức setBootstrapped trong Bootstrap.groovy bạn

Sau đó, trong RouteBuilder của bạn, bạn đặt bộ xử lý giữa thiết bị đầu cuối và điểm đến của bạn cho tất cả các tuyến đường mà bạn mong đợi thông điệp đến trước khi ứng dụng đã bắt đầu:

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