在非组件类中注入OSGi服务

Question

我尝试的方法之一是在从MessageBusListener创建FlowListener实例的同时传递服务引用。然而，当参数化服务被停用和激活回来时，我认为OSGi服务将创建一个新的服务实例并绑定到MessageBusListener，但是FlowListener仍然会有一个过时的引用。

@Component
public class MessageBusListener
{
    private final AtomicReference<QueueExecutor> queueExecutor = new AtomicReference<>();

    @Activate
    protected void activate(Map<String, Object> osgiMap)
    {
        FlowListener f1 = new FlowListener(queueExeciutor)
    }

    Reference (service = QueueExecutor.class, cardinality = ReferenceCardinality.MANDATORY, policy = ReferencePolicy.STATIC)
    protected void bindQueueExecutor(QueueExecutor queueExecutor)
    {
        this.queueExecutor = queueExecutor;
    }
}

public class FlowListener
{
    private final AtomicReference<QueueExecutor> queueExecutor;

    FlowListener(QueueExecutor queueExecutor)
    {
        this.queueExecutor = queueExecutor;
    }
    queueExecutor.doSomething() *// This would fail in case the QueueExecutor 
    service was deactivated and activated again*
}

期待其他方法，可以满足我的要求。

Answer 1

您的方法是正确的，您只需要在必要时处理停用。

如果QueueExecutor消失，MessageBuslistener将被关闭。您可以使用@deactivate方法来处理这个问题。在此方法中，您还可以调用FlowListener的sutdown方法。

如果出现了一个新的QeueExecutor服务，那么DS将创建一个新的MessageBuslistener，所以一切都应该很好。

@Reference
QueueExecutor queueExecutor;