Использование Felix Dependency Manager для создания зависимостей конфигурации

Я пытаюсь заставить работать FelixDependencyManager. Я использую Karaf 3 и тестирую 2 пакета, один для предоставления информации о конфигурации, а другой для реализации ManagedService-Interface и в зависимости от этой информации. Итак, все сводится к 3 классам:

Зависимый бандл имеет 2 класса: первый расширяет класс DependencyActivatorBase, необходимый для использования Felix DependencyManager, и реализует метод init, в котором создается и настраивается компонент:

public class ConfigAdminTester extends DependencyActivatorBase{

@Override
public void init(BundleContext context, DependencyManager manager)
        throws Exception {
    manager.add(createComponent()
            .setImplementation(ConfigTestImpl.class)
            .add(createConfigurationDependency()
            .setPid("test.configadmintest.testconfig"))
            .setCallbacks(null, "start", null, null)
            );
    System.out.println("ConfigAdminTester init finished");       
}

@Override
public void destroy(BundleContext context, DependencyManager manager)
        throws Exception {
}
}

Второй класс в комплекте — это тот, который должен обновляться службой ConfigAdmin-Service. Он реализует ManagedService и имеет метод updated, который должен вызываться при развертывании пакета и при обновлении конфигурации:

public class ConfigTestImpl implements ManagedService{
    String host;
    String port;
    int id;
    String password;

    public void start(){
    System.out.println("Host, Port, Id, Password: " + host + ", " +   port +", " + id + ", " + password);
    }
    @Override
    public void updated(@SuppressWarnings("rawtypes") Dictionary properties) throws  ConfigurationException {
        if (properties != null) {
            host= ((String)properties.get("host"));
            if (host == null) {
            throw new ConfigurationException("host", "must be specified");
            }
            port=((String)properties.get("port"));
            if (port == null) {
            throw new ConfigurationException("port", "must be specified");
            }
            id=((Integer)properties.get("id"));
            password=((String)properties.get("password"));
            System.out.println("Configuration in Bundle HttpServer was updated");
        }
        else {
            System.out.println("Properties are null");
        }    
    }

}

Второй пакет имеет только один класс, который реализует BundleActivator, получает ссылку на ConfigAdmin-Service и создает новую конфигурацию с тем же pid, который использует другой пакет:

public class ConfigCreator implements BundleActivator{
    public void start(BundleContext context) throws Exception {

    @SuppressWarnings("rawtypes")
    ServiceReference serviceRef = context.getServiceReference(ConfigurationAdmin.class.getName());
    @SuppressWarnings("unchecked")
    ConfigurationAdmin configAdmin = (ConfigurationAdmin) context.getService(serviceRef);
    Configuration config = configAdmin.getConfiguration("test.configadmintest.testconfig", null);
    Dictionary <String, Object> properties = new Hashtable <String, Object>();
    properties.put("host", "test");
    properties.put("port", "test");
    properties.put("id", 1);
    properties.put("password", "test!");
    config.update(properties);
    System.out.println("config updated");
}

Теперь проблема в том, что обновленный метод никогда не вызывается. Я получаю вывод, что инициализация ConfigAdminTest завершена, и Bundle активируется, но запуск метода обратного вызова в ConfigtestImpl никогда не вызывается. Если я просто объявляю компонент без зависимости от конфигурации, все работает нормально, метод обратного вызова выполняется, как и должно быть. Конфигурация опубликована, доступна (я проверил с помощью команды config:list) и действительна, но кажется, что конфигурация почему-то недоступна для зависимого пакета. Любая идея? Помощь очень ценится.


person user3207080    schedule 04.02.2014    source источник


Ответы (1)


Я буквально скопировал три предоставленных вами класса в свою IDE и сделал из них два пакета. Я также включил пакет, реализующий ConfigurationAdmin и DependencyManager. Когда я начал все, я сразу получил сообщение:

Configuration in Bundle HttpServer was updated

Поэтому я не уверен, что здесь пошло не так, но ваш код кажется абсолютно правильным! Позвольте мне показать вам полный вывод моего запуска, включая команды оболочки GoGo и оболочки DM:

ConfigAdminTester init finished
config updated
Configuration in Bundle HttpServer was updated
Host, Port, Id, Password: test, test, 1, test!
____________________________
Welcome to Apache Felix Gogo

g! lb
START LEVEL 1
   ID|State      |Level|Name
    0|Active     |    0|System Bundle (4.2.1)
    1|Active     |    1|Apache Felix Configuration Admin Service (1.8.0)
    2|Active     |    1|Apache Felix Dependency Manager (3.1.0)
    3|Active     |    1|Apache Felix Dependency Manager Shell (3.0.1)
    4|Active     |    1|Apache Felix Gogo Command (0.12.0)
    5|Active     |    1|Apache Felix Gogo Runtime (0.10.0)
    6|Active     |    1|Apache Felix Gogo Shell (0.10.0)
    7|Active     |    1|osgi.cmpn (4.3.1.201210102024)
    8|Active     |    1|xxx.stackoverflow.b1 (0.0.0)
    9|Active     |    1|xxx.stackoverflow.b2 (0.0.0)
g! dm
[8] xxx.stackoverflow.b1
  class b1.ConfigTestImpl registered
    test.configadmintest.testconfig configuration required available

g! 

На всякий случай я поместил код в два разных пакета. В предоставленном вами образце не отображаются пакеты или импорт, но вы не можете использовать пакет по умолчанию (пустой) в OSGi. Другой ошибкой мог быть какой-то неправильный импорт. В любом случае, если вы все еще застряли, дайте мне знать, и я буду рад предоставить полный исходный код.

person Marcel Offermans    schedule 06.02.2014