问题标签 [broker]

我正在研究 Apache WSO2 CEP，我正在尝试做一些符合我要求的场景。

首先，我执行此链接KPI Analyzer中解释的示例，我成功并正确查看了结果。在那之后，我想从这里稍微改变一下那个样本中的桶

对此

并相应地更改了元组映射。但是这个配置总是给我错误

除了 jmsbroker 之外，我无法在这些示例中使用 siddhi 语言的聚合函数（sum、avg 等）。这种情况可能有什么问题？

@Mohanadarshan

这是我的存储桶 xml 文件的最后一个版本

感谢您的帮助。

我正在尝试使用 Interactive Brokers Java API 下订单，但我得到的是 '200 | 没有为请求错误找到安全定义，我不知道发生了什么，API 文档也没有太大帮助。这是合同和订单的一段代码

我需要一些帮助来了解这里发生了什么

有人可以在经纪人网络的背景下澄清 activemq 虚拟主题的行为吗？我对订阅传播感到困惑。

例如，有一个代理与另一个代理具有网络连接器。假设代理 mq001 向代理 mq002 开放了以下网络连接器：

然后我将消费者 (A) 运行到代理 mq001 上的虚拟主题：endpointURI：activemq:Consumer.A.VirtualTopic.tempTopic

我可以在 activemq 控制台中注意到一些有趣的行为。首先，没有"VirtualTopic.tempTopic"创建主题。但是，有可用的队列（虚拟主题的基础物理队列） -Consumer.A.VirtualTopic.tempTopic 这个队列有一个活跃的本地消费者。

然后我启动另一个消费者 (B) 到相同的虚拟主题，但已经在代理 2 (mq002) 上。

endpointURI - activemq:Consumer.B.VirtualTopic.tempTopic

如果我现在看一下代理 2 上的 activemq 控制台。我仍然没有看到任何可用的虚拟主题。有另一个创建的物理队列 Consumer.B.VirtualTopic.tempTopic 有一个活动的消费者（对于 mq002 也是本地的）。

当我查看代理上的控制台时，我现在看到两个队列：

Consumer.A.VirtualTopic.tempTopic - 具有活动的本地消费者 Consumer.B.VirtualTopic.tempTopic - 具有活动的远程消费者。

因此订阅传播至少在物理队列级别上起作用。而且因为它不是双工的，所以只能从 mq002 到 mq001。

然后我向主题发布消息：

mq001 和 mq002 上的两个消费者都在使用它。在 activemq 控制台（VirtualTopic.tempTopic）中也终于有了可用的主题。

所以每个消费者只消费了一条消息。如果我用更多的消息重复它，它仍然可以正常工作。没有重复到达，也没有丢失的消息。每个物理队列上的排队消息数与虚拟主题上的数相匹配。

在经纪人网络的情况下，这正是我对虚拟主题所期望的行为。

但现在我困惑的根源：

http://activemq.apache.org/virtual-destinations.html#VirtualDestinations-AvoidingDuplicateMessageinaNetworkofBrokers

如果您使用默认网络配置，您可能会收到重复的消息。这是因为网络节点不仅会转发发送到虚拟主题的消息，还会转发相关的物理队列。

首先，我没有看到任何重复，而且效果很好。但是，如果我遵循建议并禁用物理队列目标会发生什么？

然后当我启动消费者时，我再也看不到远程消费者正在监听代理 mq001 上的物理队列 Consumer.B。如果我向虚拟主题发布消息，则它仅由 Consumer.A （本地）使用。所以看起来订阅传播对于虚拟主题被忽略并且只在物理队列上工作。

在我看来，activemq 文档有点过时了。有人可以确认或反驳吗？

提前致谢！

我想配置 3 个作为代理网络一起工作的 activemq 代理（同一台机器或 vm）。我需要遵循哪些步骤？

我一直在努力从盈透证券的文档中找出如何查询帐户详细信息，例如可用保证金、可用资金等。

我试图效仿他们的例子，但有点迷失了；我无法准确确定如何进行简单的调用以获取帐户详细信息。

谁能提供一个代码片段，或者一些关于方法的指针？

非常感激。

谢谢

如果消息中缺少时间戳标头，是否可以将代理配置为插入时间戳标头？那么如果发布客户端不添加时间戳头，那么broker是否可以插入一个时间戳值与交易所接收到消息的时刻相匹配的时间戳值呢？我应该在哪里寻找该配置？或者这是一个坏主意？

我正在尝试在 Perspective Broker 中实现一个简单的服务器回复。

可能的实施（如果可能，请建议其他人）：

客户端请求服务器执行服务器方法，服务器执行然后回复（通过执行客户端方法，其唯一目的是打印消息）：

如何实现客户端对象的抓取？有没有比抓取客户端对象并调用仅打印客户端方法更好的方法来实现服务器回复？

这是我尝试实现回复的完整代码：

[客户端]：

[服务器端]：

也许有一些更高级的 Twisted（或 Twisted PB）特性可以让这变得更简单。

文档：https ://twistedmatrix.com/documents/12.3.0/core/howto/pb-usage.html#auto3

谢谢。

我得到了我的 activemq 配置文件，我的 mule 使用“jms:activemq-connector”流动，如下所示：

这是我的 activemq.xml

看起来像那些 url 的“作品”的故障转移。

问题，我应该如何测试故障转移？？？有什么建议么？这是我第一次实现这个。

谢谢。

作为 ActiveMQ 的新手，想了解在单个 ActiveMQ 中配置多个代理实例和配置多个 ActiveMQ 实例（安装）每个包含一个代理实例的优缺点。

简化上面，什么时候使用，1. 两个 ActiveMQ 安装（即 2 个单独的 AMQ 主目录），每个都有一个代理运行 2. 单个 AMQ 安装，2 个代理运行（配置 activemq.xml）

我的应用程序与两个代理进行通信，但这两种配置在故障转移场景或性能方面有什么不同吗？

我有一个使用 activemq 5.4.0 的 activemq 代理网络。我有一个带有代理和消费者的中央服务器以及许多带有本地代理和生产者的客户端。我需要将activemq 升级到5.8.0 版本。升级服务器，在本地代理中我继续看到中央消费者，但消息仍保留在本地代理中。

对于broker网络，是否必须有相同版本的activemq？

谢谢