0

嗨，我有一个输入适配器，可以从 rabbitmq 队列中读取消息。我看到当服务器启动时，在适配器上进行了 subscribe() 调用。但是当 wso2 服务器被关闭时，我没有看到正在调用 unsubscribe()。这使适配器读取并删除消息，直到 jvm 死亡 - 即使 cep 的其他组件似乎已关闭。有没有其他人看到这个？

4

1 回答 1

0

到目前为止我们还没有遇到这个问题，但我认为有可能会发生上述问题。我们会考虑在下一个版本中修复它。您能否就此提出一个 jira [1]。目前，您可以通过取消订阅您编写的适配器的 deactivate() 方法中的回调来解决此问题。您可以实现如下

protected void deactivate(ComponentContext context);

查看 OSGI 文档以获取更多信息。

[1] https://wso2.org/jira/browse/CEP

于 2014-10-10T06:15:02.447 回答