从 Java 对象发布到 Clojure 频道
Publish to Clojure channel from Java object
我有一个 java 对象用于连接 Weblogic JMS 服务器。我希望能够从 JMS 获取这些消息并在 clojure 中使用它们。以我有限的知识，我认为最好的方法是通过 clojure 异步库中的通道。但是我不确定我是否可以从 Java 对象发布到 clojure 频道。
我理想的流程是：
- Java 对象接收来自 JMS 订阅的消息
- Java 向频道发布消息
- Clojure 有一个线程监听该通道并接收
留言
- 我在收到来自 clojure 的消息后进行处理
频道。
我还需要确保这些消息的接收顺序与我从 Java 收到的顺序相同。
有没有一种方法可以使用异步库通道在 java 对象中工作，或者我用这种方法找错了树？
我按照此 link 上的第二条评论在我的 java 来源中创建了一个频道来解决了这个问题。然后将通道分配给一个通用对象，并向我的 java 通道源添加访问器方法。
我有一个 java 对象用于连接 Weblogic JMS 服务器。我希望能够从 JMS 获取这些消息并在 clojure 中使用它们。以我有限的知识，我认为最好的方法是通过 clojure 异步库中的通道。但是我不确定我是否可以从 Java 对象发布到 clojure 频道。
我理想的流程是：
- Java 对象接收来自 JMS 订阅的消息
- Java 向频道发布消息
- Clojure 有一个线程监听该通道并接收 留言
- 我在收到来自 clojure 的消息后进行处理 频道。
我还需要确保这些消息的接收顺序与我从 Java 收到的顺序相同。
有没有一种方法可以使用异步库通道在 java 对象中工作，或者我用这种方法找错了树？
我按照此 link 上的第二条评论在我的 java 来源中创建了一个频道来解决了这个问题。然后将通道分配给一个通用对象，并向我的 java 通道源添加访问器方法。