1

我在 DS 中编写了一个 @component,它应该在多个实例中被实例化和激活。为了测试我已经编写了一个 pax 考试测试,我在其中启动 karaf 并添加了 scr。一切正常,但是......在测试方法运行之前它不会实例化服务,因此我没有空间进行断言等。

@Test
public final void testing() throws Exception { 
props = createProperties(user, pass, host);
cfg = configurationAdmin.
     createFactoryConfiguration(CouchbaseConnectionProvider.SVC_NAME);
cfg.update(props);

final ServiceTracker tracker = new ServiceTracker(bundleContext, CouchbaseConnectionProvider.class, null);
tracker.open();

CouchbaseConnectionProvider svc = (CouchbaseConnectionProvider) tracker.waitForService(5000);
// It will wait 5s and after testing exits it will create the service
}

我在这里做错了什么?因为当方法退出时,它将正确创建和激活具有所有属性的服务。

我可以补充一点,使用线程“ion(3)-127.0.0.1”的测试方法以及当 DS 实例化时使用线程“84-b6b23468b652)”。

干杯,马里奥

更新 3 实际上有两个错误,一个在我身边,一个在其他地方(在 felix CM 中?),因为我的接口 impl 包可以在一段时间后访问配置(当容器关闭时),但它确实应该绑定到pax 测试包(当然还有 CM 本身)并且在容器关闭时从未“免费:d”。我不知道那个错误在哪里 - 我将结束一个简约的 mvn 项目并尝试 felix cm 家伙,我将在此处发布更新。

更新 2如果有人有兴趣关注进度(如果有错误;), 我已经提交了一个错误(https://ops4j1.jira.com/browse/PAXEXAM-725

更新 1 这是我在测试类中的配置

package se.crossbreed.foundation.persistence.provider.couchbase;

@RunWith(PaxExam.class)
@ExamReactorStrategy(PerClass.class)
public class CouchbaseConnectionProviderTests extends CbTestBase {
  ...
}

这是 testclass 中的配置,它将使用基类作为基选项。

@org.ops4j.pax.exam.Configuration
public Option[] config() {
    List<Option> options = super.baseConfig();
    options.addAll(Arrays
            .asList(features(karafStandardRepo, "scr"),
                    mavenBundle()
                            .groupId("se.crossbreed.foundation.persistence")
                            .artifactId(
                                    "se.crossbreed.foundation.persistence.core")
                            .versionAsInProject(),
                    mavenBundle().groupId("io.reactivex")
                            .artifactId("rxjava").versionAsInProject(),
                    mavenBundle()
                            .groupId("se.crossbreed.ports.bundles")
                            .artifactId(
                                    "se.crossbreed.ports.bundles.couchbase.java-client")
                            .versionAsInProject(),
                    mavenBundle()
                            .groupId("se.crossbreed.foundation.persistence")
                            .artifactId(
                                    "se.crossbreed.foundation.persistence.provider.couchbase")
                            .versionAsInProject()));

    // above bundle is the one I'm trying to test and where
    // this test resides in (project wise)
    return options.toArray(new Option[] {});
}

基本配置来自基类

protected List<Option> baseConfig() {
    return new ArrayList<Option>(
            Arrays.asList(new Option[] {
                    logLevel(LogLevel.INFO),
                    karafDistributionConfiguration().frameworkUrl(karafUrl)
                            .unpackDirectory(new File("target", "exam"))
                            .useDeployFolder(false),
                    configureConsole().ignoreLocalConsole(),
                    mavenBundle().groupId("biz.aQute.bnd")
                            .artifactId("bndlib").version("${version.bndlib}"),
                    mavenBundle()
                            .groupId("se.crossbreed.foundation")
                            .artifactId(
                                    "se.crossbreed.foundation.core.annotations")
                            .versionAsInProject(),
                    mavenBundle()
                            .groupId("se.crossbreed.foundation")
                            .artifactId(
                                    "se.crossbreed.foundation.core.interfaces")
                            .versionAsInProject() }));
}

测试包是

package se.crossbreed.foundation.persistence.provider.couchbase;

并且 CouchbaseConnectionProvider 在同一个包上

package se.crossbreed.foundation.persistence.provider.couchbase;

import se.crossbreed.foundation.persistence.core.CbDbConnectionProvider;

public interface CouchbaseConnectionProvider extends CbDbConnectionProvider {
    public final static String SVC_NAME = "couchbase.connection.provider";
}

实施:

package se.crossbreed.foundation.persistence.provider.couchbase.impl;

@Component(immediate = true, name = 
    CouchbaseConnectionProvider.SVC_NAME, provide = {
    CouchbaseConnectionProvider.class, CbDbConnectionProvider.class,
    CbService.class }, properties = { "providerType=DOCUMENT" }, 
    configurationPolicy = ConfigurationPolicy.require)
    public class CouchbaseConnectionProviderImpl implements
    CouchbaseConnectionProvider { ... }

这是 Couchbase Provider 的项目结构和我未能开始工作的测试(直到测试运行后;)。

couchbase 提供者的项目结构和测试

4

3 回答 3

1

(我实际上没有看到您的代码有任何问题,ConfigurationAdmin 应该异步工作。测试后出现的新服务仍然看起来像一个同步问题。在这种情况下,此设置可能会解决它。)

您可以使用 pax-exam-cm 来创建带有其他选项的工厂配置,而不是在测试方法中创建配置:

@org.ops4j.pax.exam.Configuration
public Option[] config() {
    List<Option> options = super.baseConfig();
    options.addAll(Arrays
        .asList(features(karafStandardRepo, "scr"),
        //missing conversion: putAll() needs a Map        
        ConfigurationAdminOptions.factoryConfiguration(CouchbaseConnectionProvider.SVC_NAME)
                        .putAll(createProperties(user, pass, host)).create(true).asOption(),
                mavenBundle()
                        .groupId("se.crossbreed.foundation.persistence")
                        .artifactId(
                                "se.crossbreed.foundation.persistence.core")
                        .versionAsInProject(),
                mavenBundle().groupId("io.reactivex")
                        .artifactId("rxjava").versionAsInProject(),
                mavenBundle()
                        .groupId("se.crossbreed.ports.bundles")
                        .artifactId(
                                   "se.crossbreed.ports.bundles.couchbase.java-client")
                        .versionAsInProject(),
                mavenBundle()
                        .groupId("se.crossbreed.foundation.persistence")
                        .artifactId(
                                "se.crossbreed.foundation.persistence.provider.couchbase")
                        .versionAsInProject()));

    // above bundle is the one I'm trying to test and where
    // this test resides in (project wise)
    return options.toArray(new Option[] {});
}

Maven设置:

<dependency>
    <groupId>org.ops4j.pax.exam</groupId>
    <artifactId>pax-exam-cm</artifactId>
    <version>${exam.version}</version>                
</dependency>

然后,您也可以简单地使用@Inject注释来获取CouchbaseConnectionProvider测试内部。

@Inject
CouchbaseConnectionProvider svc;
于 2015-07-08T14:48:49.590 回答
0

我怀疑测试会自行部署 CouchbaseConnectionProvider 接口。因此,您尝试使用与实际服务提供的接口不同的接口来检索服务。

您应该尝试为 CouchbaseConnectionProvider 所在的包添加导入和导出到您的测试包。

为此,请使用 ProbeBuilder

@ProbeBuilder
public TestProbeBuilder probeConfiguration(TestProbeBuilder probe) {
    probe.setHeader(Constants.IMPORT_PACKAGE, "..");
    probe.setHeader(Constants.EXPORT_PACKAGE, "..");
    return probe;
}
于 2015-07-07T15:54:47.227 回答
0

感谢你们的意见 - 我选择自己回答这个问题,因为我的代码中有一个错误并得到了 Christoph 的帮助。

如果其他人做了我所做的事情,我在这里引用他的答案。

问题是我没有在 createFactoryConfiguration 中通过 (pid, null) 将配置所有权设置为匿名。相反,我使用了 createFactoryConfiguration(pid) 然后它绑定到当前正在执行的包,而不是我正在测试的包。正如 Christoph 解释的那样,我可以获取服务包的包位置并明确设置它。

干杯,马里奥

这是克里斯托夫·劳布里希的回答

“Christoph Läubrich 添加了一条评论 - 13 分钟前

好的,我想我知道现在可能是什么问题:您正在使用 createFactoryConfiguration(java.lang.String factoryPid),这意味着您将创建一个专门绑定到您的包的配置!因此不允许其他捆绑软件访问配置!使用 createFactoryConfiguration(java.lang.String factoryPid, java.lang.String location) 代替位置的空参数!通过这种方式,您可以创建一个匿名配置,该配置将绑定到获取此配置的第一个包。或者,您可以获取目标包的位置并将其作为参数显式传递,但这通常不是必需的。如果这仍然不起作用,我们必须仔细查看您的配置,连接到 karaf shell(在断点处停止)并获取所有捆绑包的列表(捆绑包:list) 和所有组件的列表 (scr:list)。此外,您应该收集有关探测包和应提供服务的包的详细信息(包:导入)。”

于 2015-07-09T11:45:48.220 回答