问题标签 [messagebroker]

我正在尝试从 ActiveMQ 5.6 切换到 Apollo 1.5。我有两个软件正在交换消息，使用发布/订阅主题。

• 第一个是 c++ 并使用带有 tcp 的 openwire
• 第二个是 Javascript 并使用 stomp 和 websockets

使用 ActiveMQ 一切正常，我发送的消息可以在两个软件上读取和写入，此后我没有更改客户端。

现在，我从 c++ 软件（使用 openwire）发送消息，并尝试用 JS 软件读取它们，但我得到了错误。事实上，我收到带有标题内容类型的消息：“protocol/openwire”，但我期待 stomp。

这就是我配置 apollo.xml 连接器部分的方式：

我还尝试在 tcp 和 ws 连接器中使用 <detect />，它应该自动检测客户端协议，但也不起作用。

有人可以帮我解决这个问题吗？

谢谢，

编辑 ：

我发现我确实收到了 stomp 协议消息，但它们的格式非常奇怪，甚至包含使 stomp.js 无法解析消息并正确填充消息正文的非文本字符。

这是从 activemq openwire 和 apollo openwire 收到的相同消息，使用相同的 c++ 发布者和 js 订阅者：

活跃的MQ

阿波罗

你认为这可能是阿波罗的问题吗？

这个问题与我之前问过的一个问题有关https://stackoverflow.com/questions/13158412/message-broker-sending-email 问题如下：我通过 Message Broker 电子邮件节点发送电子邮件，而 Lotus Notes客户端正确显示邮件正文，但主题行乱码；它似乎无法解析主题，并显示如下： =?UTF8?Q?Application_=E2=84=96_TESTIROVANE._Approval?= 消息和主题行都在其他客户端中正确显示，例如 Gmail 网络客户端. 我应该怎么做才能让 Lotus Client 解析 header 并正常显示？我应该以某种方式配置客户端本身还是配置电子邮件节点？

我正在开发一个简单的消息流，它使用 Log4j 记录各个阶段的状态。但是，当我尝试运行此流程时，我收到以下错误。我在消息流中使用了 Log4jNode。

尝试解析''com.ibm.broker.IAM3.Log4jNode.initLog4j''例程“ initLog4j ”引用的 Java 类或方法时发生错误

正如错误消息所述，我猜它找不到 log4jNode 的参考。但我找不到任何可以确定这一点的帮助。请高手帮帮我。

我遇到了消息代理 7.0.0.5 的以下问题这是我的流程：

我想要它做什么： 1. 接受 XML，解析，使用 XMLNSC 2. 然后我想要执行一些业务逻辑，但是让我们跳过它并关注以下内容 - 我想抛出两个用户异常 - 一个在模块中GoodReport，另一个 - 在模块 BadReport 中，因此，在 Out 和 Catch 流中处理后，我假设我的消息到达Backout Queue （我为我的队列创建了一个，并将阈值设置为 10）并被发送回MQInput 以便再次处理。所以我希望 Backout 队列中有 10 条消息，但相反 - 我什么也没得到

我可以看到在我的流程中抛出了两个错误，但最让我感到奇怪的是跟踪中的最后几行—— “XMLNS”域是从哪里出现的？ 我只使用 XMLNSC 域。

为什么消息没有出现在 Backout 队列中？

先感谢您！

塔蒂亚娜。

这是跟踪：

2012-12-17 19:25:54.692283 5756 RecoverableException BIP2488E: ('.Esql6_1Flow_Report.Main', '19.4') 执行 SQL 语句“THROW EXCEPTION MESSAGE 3 VALUES ('NO_SUCH_SOURCE');''时检测到错误。消息代理在执行给定语句时检测到错误。已引发异常以缩短 SQL 程序。有关错误的详细信息，请参阅以下消息。

2012-12-17 19:25:54.692302 5756 用户异常 ?????????? 3 ？？？？？？？？？BIPmsgs.properties 2012-12-17 19:26:52.830982 5756 错误 BIP2628E：在输入节点“Esql6_1Flow.MQInput”上检测到异常情况。输入节点“Esql6_1Flow.MQInput”在处理消息时检测到错误。消息流已回滚，如果消息正在工作单元中处理，它将保留在输入队列中以再次处理。以下消息将指示此异常的原因。检查随后的错误消息以确定生成异常的原因，并按照这些消息的描述采取措施。

2012-12-17 19:26:52.831005 5756 RecoverableException BIP2230E：处理节点“Esql6_1Flow.BadReport”中的消息时检测到错误。消息代理在处理节点“Esql6_1Flow.BadReport”中的消息时检测到错误。已引发异常以缩短消息的处理时间。有关错误的详细信息，请参阅以下消息。

2012-12-17 19:26:52.831012 5756 RecoverableException BIP2488E: ('.Esql6_1Flow_Compute.Main', '13.4') 执行 SQL 语句''THROW EXCEPTION MESSAGE 3 VALUES ('NO_SUCH_SOURCE');''时检测到错误。消息代理在执行给定语句时检测到错误。已引发异常以缩短 SQL 程序。有关错误的详细信息，请参阅以下消息。

2012-12-17 19:26:52.831020 5756 用户异常 ?????????? 3 ？？？？？？？？？BIPmsgs.properties

2012-12-17 19:26:53.831737 5756 错误 BIP2648E：消息退回到队列；节点“Esql6_1Flow.MQInput”。节点“Esql6_1Flow.MQInput”收到一条消息，由于消息流的主路径中的处理错误，该消息先前已被撤销一次或多次。未连接故障终端，因此消息代理将消息直接放入与此节点关联的重新排队或死信回退队列。消息的 MQMD 'backoutCount' 现在等于为 WebSphere MQ 输入队列定义的 'backoutThreshold'。检查以前的消息和消息流以确定消息被回退的原因。如果可能，请纠正这种情况。

2012-12-17 19:26:53.832435 5756 UserTrace BIP2638I：MQ 输出节点“Esql6_1Flow.MQInput”试图将消息写入连接到队列管理器“testQueueManagerName”的队列“SYSTEM.DEAD.LETTER.QUEUE” . MQCC 为“0”，MQRC 为“0”。

2012-12-17 19:26:53.832466 5756 UserTrace BIP2615I：WebSphere MQ 输入节点“Esql6_1Flow.MQInput”已将消息回退到回退重新队列或死信队列。消息回退处理已被调用，并且消息已通过写入回退重新队列或死信队列来回退，这由 WebSphere MQ 队列管理器和队列配置确定。无需用户操作。

2012-12-17 19:27:31.087949 4380 UserTrace BIP2632I：消息接收并传播到 MQ 输入节点“.InputNode”的“输出”终端。

2012-12-17 19:27:31.088045 4380 UserTrace BIP6060I：代表节点“.InputNode”创建解析器类型“属性”，以处理从偏移量“0”开始的长度为 0 字节的传入消息的一部分。

2012-12-17 19:27:31.088066 4380 UserTrace BIP6061I：代表节点“.InputNode”创建解析器类型“MQMD”，以处理从偏移量“0”开始的长度为“364”字节的传入消息部分。根据来自先前解析器的值“MQHMD”选择的解析器类型。

2012-12-17 19:27:31.088092 4380 UserTrace BIP6069W：代理无法处理数据类型为“””的消息。消息代理收到一条需要处理“'”' 类型数据的消息，但该代理没有能力处理这种类型的数据。检查发送到消息代理的消息和节点的配置数据。如果消息要由代理处理，则必须删除对不受支持的数据类型的引用。

2012-12-17 19:27:31.088113 4380 UserTrace BIP6061I：代表节点“.InputNode ”创建解析器类型“XMLS ”，以处理从偏移量“364”开始的长度为“236”字节的传入消息部分。根据先前解析器中的值“XMLS”选择的解析器类型。

我正在使用消息集来解析文件，但出现以下异常。我无法理解它的实际含义。请帮助我理解并解决问题。

关于 ws-event 演示 q1 的消息代理： http ://wso2.org/library/knowledge-base/2012/06/publishing-messages-message-broker-using-event-mediator

客户端如何调用代理服务

q2：Event Sink URL 目标服务演示

我有一个作为 Web 服务公开的消息流。在该流程中，我们正在调用另一个 Web 服务。流主要是通过将 wsdl 从消息集中拖到 IBM Websphere Message Broker Tool Kit 的设计器来生成的。这是我的流程：

SoapInput--> SubFlow to Expose Service--> Subflow to invoke Service-->SoapReply

SubFlow to Expose Service通过拖动 WSDL 并选择“公开为服务”生成。

Subflow to invoke Service通过拖动 WSDL 并选择“Invoke as a service”来生成。

从服务端获取无效参数错误。我尝试调用的所有服务都没有收到相同的错误。这只发生在一项服务中。我在流量方面做错了吗？

我们知道，在 kafka 0.7 中，我们可以为 producer 指定 zk.connect，以便 producer 可以找到 broker 的添加和删除。但是在 kafka 0.8 中，我们不能为生产者指定 zk.connect。kafka 0.8中的生产者可以找到吗？如果不是，系统的扩展性不比0.7版本差吗？

对于使用消息代理 7.0 和 MQ 7.0 开发简单的发布/订阅流程，我真的很感激

我的流程应该接受没有标头的某个消息，根据字段过滤它（过程，如果值为“是”），然后将正文发布到消息节点中列出的所有队列

这是我的流程：

我在 MQ 中注册了一个主题和一个订阅，但我几乎不知道接下来应该做什么。我使用 RFHUtil 测试点对点应用程序，但不知道如何在开发发布订阅时使用它。

问题： 1. 只使用一个简单的队列作为发布者是否正确（在 MQ 输入中我只是设置“IN”，队列，我在 MQ 中） 2. 我如何在这个流程中注册订阅者/多个订阅者？什么是订阅点？

这只是一个学习任务。

欢迎任何帮助！

我有一个可配置的服务（CDServer）。当我尝试部署使用 CDInput 节点（使用可配置服务）的 WMB 流时，出现以下错误：

文件路径可从我的 Windows 资源管理器访问。文件夹“myfolder”在远程计算机上共享。

我不知道错误可能出在哪里。我尝试将文件路径更改为其他格式（192.168.45.91\myfolder），但仍然无法正常工作。

我在用着：

WMB 8.0.0.1 MQ 7 Sterling Connect Direct 4.6

非常感谢您对此问题的任何帮助。