Я пытаюсь заставить работать 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) и действительна, но кажется, что конфигурация почему-то недоступна для зависимого пакета. Любая идея? Помощь очень ценится.