Как запустить маршруты Camel на подчиненном ActiveMQ, только когда подчиненный становится активным при отработке отказа? - PullRequest
Новая
       42

Как запустить маршруты Camel на подчиненном ActiveMQ, только когда подчиненный становится активным при отработке отказа?

6 голосов
/ 14 января 2010

У меня есть постоянный потребитель для удаленной очереди JMS во встроенной маршрутизации Camel. Возможно ли иметь такой тип маршрутизации с конфигурацией master-slave? Теперь кажется, что маршруты Camel запускаются и активируются уже при запуске ведомого ActiveMQ, а не при фактическом восстановлении после сбоя.

Теперь он заставляет подчиненный экземпляр получать те же сообщения, которые также отправляются ведущему, и это приводит к тому, что повторяющиеся сообщения поступают в очередь при отработке отказа.

Я использую ActiveMQ 5.3 вместе с Apache Camel 2.1.

Ответы [ 3 ]

3 голосов
/ 01 мая 2012

К сожалению, когда запускается ведомый брокер, CamelContext запускает вместе с маршрутами. Однако вы можете сделать это, выполнив следующие действия:

В camelContext, развернутом с ведомым брокером, добавьте следующий атрибут autoStartup, чтобы предотвратить запуск маршрутов: 

<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring" autoStartup="false">

...

</camelContext>

Далее необходимо создать класс, который реализует интерфейс службы ActiveMQ. Пример этого будет следующим: 

package com.fusesource.example;

import org.apache.activemq.Service;
import org.apache.camel.spring.SpringCamelContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
* Example used to start and stop the camel context using the ActiveMQ Service interface
*
*/
public class CamelContextService implements Service
{
private final Logger LOG = LoggerFactory.getLogger(CamelContextService.class);
SpringCamelContext camel;

@Override
public void start() throws Exception {
    try {
        camel.start();
    } catch (Exception e) {
        LOG.error("Unable to start camel context: " + camel);
        e.printStackTrace();
    }
}

@Override
public void stop() throws Exception {
    try {
        camel.stop();
    } catch (Exception e) {
        LOG.error("Unable to stop camel context: " + camel);
        e.printStackTrace();
    }
}

public SpringCamelContext getCamel() {
    return camel;
}

public void setCamel(SpringCamelContext camel) {
    this.camel = camel;
}
}

Затем в файле конфигурации брокера activemq.xml добавьте следующее для регистрации службы: 

<services>
      <bean xmlns="http://www.springframework.org/schema/beans" class="com.fusesource.example.CamelContextService">
          <property name="camel" ref="camel"/>
      </bean>
</services>

Теперь, когда подчиненный брокер вступает во владение как мастер, метод запуска будет вызываться для класса обслуживания, и маршруты будут запущены.

Я также разместил блог об этом здесь: http://jason -sherman.blogspot.com / 2012/04 / activemq-how-to-starttop-camel-rout.html

1 голос
/ 16 февраля 2010

это не должно быть проблемой, потому что контекст / маршруты Camel на ведомом устройстве не запустятся, пока он не станет ведущим (когда мастер хранения сообщений освобождает мастер)

0 голосов
/ 05 января 2013

С помощью верблюжьей политики вы можете приостановить / возобновить определенные маршруты в зависимости от ваших условий. http://camel.apache.org/routepolicy.html

Существует существующий ZookeeperRoutePolicy, который можно использовать для выбора лидера. http://camel.apache.org/zookeeper.html (см. Внизу страницы)

...