问题标签 [messagebroker]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
266 浏览

jms - WSO2 消息代理主题发布者

我正在开发 WSO2 MB 2.0.0。

我的要求是编写一个 JAVA 代码来将消息发布到特定主题。我在 Message Broker 中创建了一个主题。现在我想创建一个与该主题的连接并发布/发布关于该主题的消息。

我在http://docs.wso2.org/wiki/display/MB200/Queue+sender+and+queue+receiver上的文章中使用 JMS 对队列做了同样的事情

请在这方面帮助我。

谢谢。

0 投票
1 回答
2810 浏览

trace - IBM Message Broker:可配置的跟踪节点文件路径

我正在尝试创建几个跟踪节点,每个节点都有一个可配置的文件路径。

我更喜欢通过消息代理中的可配置服务,但有可能吗?如果没有,还有其他方法可以使它们可配置吗?

0 投票
4 回答
6215 浏览

java - 将xml传入文件转换为文本

我通过 Websphere Message Broker 收到一个 XML 文件,但是当我使用 Java 处理它时,它在输出中给了我一个非格式化文件。

XML 输入文件:

Java 计算(用于处理消息):

XML 输出文件: 在此处输入图像描述

就像它无法识别任何 utf-8 字符一样:引号<>等...所以我认为将传入的文件转换为文本将解决问题。但我不知道该怎么做,或者它是否是最好的解决方案。

你对此有什么想法吗?谢谢 :)

编辑:消息不应该只是被转义,它应该被转换并很好地编码到输出中。

0 投票
1 回答
127 浏览

c++ - 如何在不使用 make 文件的情况下运行 ac 代理示例程序?

我想在不使用 make 文件的情况下在 apache qpid c++ 代理中运行一个 helloworld 示例。如果是这样,如何继续以及我需要包含哪些库?

0 投票
1 回答
590 浏览

websphere - Websphere 消息代理的输入

我需要将数据从 Oracle DB 发送到 SFDC 帐户。

场景:Oracle DB -> WebSphere Message Broker(MB) -> WebSphere Message queue(MQ) -> DataPower (Service) -> SFDC account

我不确定如何将数据推送到 MB?MB 是否有能力从任何来源提取数据?

如果它不具备这种能力,那么如何将数据从 Oracle DB 移动到 WebSphere Message Broker(MB)?一般使用什么通讯协议?如何将 Oracle DB 集成到 WebSphere Message Broker(MB)?

0 投票
0 回答
85 浏览

c++ - 我正在尝试安装 apache qpid 在进行 make 时出现以下错误

我正在尝试通过 svn checkout 安装 apache qpid,我已经安装了所有工具,同时我得到了错误

svn co http://svn.apache.org/repos/asf/qpid/trunk

0 投票
1 回答
1739 浏览

java - AS400 DB 连接出错,下一次调用时未删除结果集数据

我正在尝试AS400 DB从 Java 计算节点连接到一个但出现错误。你能给些建议么。

我的测试场景是:

  1. 我的代理流程每 9 秒触发一次,以在其中运行选择和删除行AS400 DB

  2. 连接到AS400 DB使用JDBC_TransactionType.MB_TRANSACTION_AUTO.

    try { //获取到 AS400 服务器的连接 if (conn == null) try { conn = getJDBCType4Connection("AS400db",JDBC_TransactionType.MB_TRANSACTION_AUTO); strSelectStoredProcName = (String)getUserDefinedAttribute("SelectStoredProcName"); 结果 = 新 CDBItaly_CoreSelectCustomerDetails().retrievePPWICustomerDetails(conn, strSelectStoredProcName);

    } 捕捉(异常 e){}

  3. 一次从 ResultSet 中获取行并获得正确的结果 - OK

  4. 使用 rs.DeleterOW 从表中删除所有行,这意味着 ResultSet 下次不应该返回任何内容。

  5. 再次尝试获取(现在它应该返回 0 行)。但它返回与步骤 2 中完全相同的行,即使数据库表为空。

  6. 如果我重新启动代理流程,它会再次正常工作。

现在,如果我将代码更改如下:

我收到一个错误:java.sql.SQLException连接不存在

0 投票
1 回答
1463 浏览

java - LMAX Disruptor 如何解决典型的消息代理问题?

我对LMAX Disruptor的理解是,它是一个 JAR,里面装满了可怕的快速、可怕的并发 Java 代码,每秒可以处理 2000 万条消息(如果使用正确的话)。

我们目前有一个 ActiveMQ 实例,它在整个过程中运行速度很慢,大约每秒 400 条消息。我想知道我们是否会从重构代码以使用 LMAX 中受益,但有以下担忧:

  • 如何拥有 1 个发布者和多个(竞争)消费者
  • LMAX 如何存储/存放它的信息?在记忆中?
  • 故障转移 - LMAX 是否有故障转移协议/机制
  • 磁盘 I/O - LMAX 可以将未使用的消息保存到磁盘并在以后恢复它们吗?

而且,如果我对所有这些完全不了解,并且似乎完全误解了 LMAX Disruptors 的使用,那么有人可以提供一个具体的例子来说明何时使用它吗?提前致谢!

0 投票
1 回答
1431 浏览

wso2 - 如何将消息从 ESB 的主题发送到消息代理的队列

我在 ESB 中创建了主题,该主题由 ESB 中创建的代理订阅。在我的代理中,我提供了我在 WSO2 消息代理中创建的队列端点。因此,当我在代理订阅的队列中发布消息时,该消息应该进入 MB 队列,但这并没有发生。我应该怎么做才能实现这一目标?我的代理代码是:

我应该怎么做,当我在主题中发布我的消息时,它应该在消息代理队列中可见?

0 投票
1 回答
463 浏览

jms - 我如何以及在哪里可以在 ESB 中使用消息存储和消息处理器?

我在端口号 9443(esb1) 和 9446(esb2) 处使用了 WSO2 ESB 4.6 的两个实例,还在 9444 处使用了 Message Broker 2.0.1。我正在使用此 url 来执行我的任务:http ://wso2.org/图书馆/文章/2013/03/configuring-wso2-esb-wso2-message-broker。我已经使用上面的链接完成了队列到队列发送接收示例。一切正常。但问题是当我向 esb1 发布任何消息时,它会反映到 esb2,因为 esb2 作为我的订阅者工作。我希望消息存储应该存储从 esb1 传递的消息,并根据某些事件向 esb2 提供 esb1 发送的消息。提前致谢。当我激活我的按摩处理器时,我不断收到此错误: