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 消息发送与获取

IBM WebSphere MQ安装集成

IBM WebSphere MQ安装集成

IBM Websphere MQ 基本实验操作

连接到 IBM Websphere MQ 时出现 NullPointerException

如何将用户定义的用户名从 IBM Websphere Application 服务器传递到 AS400 MQ 服务器进行身份验证?