骆驼无缘无故地停下来

Question

我有一个bean生产者和一个bean消费者，在一条路由中使用。生产者是通过一个线程产生的，并监听hazelcast队列上的数据（它可能是其他任何东西，甚至是本地随机生成的数据）。

数据被发送到sedaendpoint，以确保并发性。使用者获取数据并将其转发到另一个hazelcast队列。但也可能是其他任何东西。

[                          main] MainSupport                    INFO  Apache Camel 2.10.3 stopping
[                          main] DefaultCamelContext            INFO  Apache Camel 2.10.3 (CamelContext: camel-1) is shutting down
[                          main] DefaultShutdownStrategy        INFO  Starting to graceful shutdown 1 routes (timeout 300 seconds)
[el-1) thread #2 - ShutdownTask] DefaultShutdownStrategy        INFO  Waiting as there are still 1 inflight and pending exchanges to complete, timeout in 300 seconds.

然后在300秒内静止处理并停止。

下面是一些代码：

制片人：

   public void run()
    {
        try
        {
            IRequest service = ProxyHelper.createProxy(context.getEndpoint("seda:echo"), IRequest.class);

            BlockingQueue<Request> q = client.getQueue(MainApp.sQueueReceive);

            while(true)
            {
                Request request;
                request = q.take();
                // no response awaited
                service.request(request);
            }
        }

   public void onMessage(Request request)
    {
        nb_forwarded++;
        BlockingQueue<Request> q = MainApp.client.getQueue(MainApp.sQueueForward);
        try
        {
            q.put(request);
        }
        catch (InterruptedException e)
        {
            exit(2);  --> it does not happen
        }

from("seda:echo")
.setExchangePattern(ExchangePattern.InOnly)
.bean(new HazelcastForwarder(), "onMessage");

谢了！

Answer 1

启用调试或跟踪日志记录，以揭示camel停止的真正原因。可能是封闭容器正在停止（如果您在某物中运行camel）或类似的情况。