IBM Websphere MQ 到 Apache Apex Operator Stream?
Posted
技术标签:
【中文标题】IBM Websphere MQ 到 Apache Apex Operator Stream?【英文标题】:IBM Websphere MQ to Apache Apex Operator Stream? 【发布时间】:2017-05-22 19:07:45 【问题描述】:我一直在广泛地搜索 INTERNET,以寻找一种在 Apache Apex 中使用 web-sphere MQ 将 MQ 消息流式传输到 DAG 的方法。但是,似乎没有关于此事的 IBM 文档。
我知道它可能类似于 ActiveMQ,我可能只需要传入 websphere Jars,但是我不知道从哪里开始。
@Override
public void populateDAG(DAG dag, Configuration conf)
JMSStringInputOperator amqInput = dag.addOperator("amqIn",
new JMSStringInputOperator());
LineOutputOperator out = dag.addOperator("fileOut", new LineOutputOperator());
dag.addStream("data", amqInput.output, out.input);
【问题讨论】:
【参考方案1】:您是否查看了操作员的测试用例,看看它是否有助于配置?
https://github.com/apache/apex-malhar/blob/master/library/src/test/java/com/datatorrent/lib/io/jms/JMSStringInputOperatorTest.java
【讨论】:
【参考方案2】:您可以使用 Apex (malhar) 中的 JMS 输入运算符来读取 IBM MQ 系列,但您需要适用于 v6 和 v8 服务器的 JMS MQ 系列驱动程序 (v6)。我没有方便司机使用的链接,但如果您找不到,请告诉我,我会看看能不能找到。
【讨论】:
IBM MQ v6 自 2012 年以来一直不受 IBM 支持,它可能可以工作,但如果出现问题,您将无法从 IBM 获得任何支持。以上是关于IBM Websphere MQ 到 Apache Apex Operator Stream?的主要内容,如果未能解决你的问题,请参考以下文章
连接到 IBM Websphere MQ 时出现 NullPointerException
如何将用户定义的用户名从 IBM Websphere Application 服务器传递到 AS400 MQ 服务器进行身份验证?