问题标签 [broker]

我运行一个带有两个队列的 ActiveMQ 5.5.1 代理。客户端产生消息（从许多小到一些显着大小）并将它们放入队列 1，消费者从队列中以他们的速度从队列中提取消息（消息预取 = 0）。消息在事务中发送。消费者然后计算一些东西，并在他们完成计算后将答案消息放入队列 2。客户端从该队列中获取应答消息。
持久性是通过 kahaDB 实现的。生产者流量控制已启用，但未达到内存限制。
这工作正常，吞吐量似乎也不是问题。

但是，有时我会在代理上看到以下两个异常。谁能给我一个暗示他们可能是什么意思？我在 ActiveMQ 文档或 Google 中也找不到任何有用的东西。

非常感谢，杰耶夫

和

我正在学习 wxPython 和 twisted 的 Perspective Broker。我被指派一起使用它们来生成聊天客户端（我已经编写了服务器和基于控制台的客户端。）

这就是让我难过的地方：PB 有它自己的带有回调等的“流程”，这与 wxpython 的事件驱动流程并不直观地相吻合。我应该使用什么样的程序结构来让两者合作？

我已经尝试使用程序的twisted pb客户端部分以本地方法从服务器获取和存储信息，然后wxpython gui可以调用以响应某些事件，并在开始时使用来设置在线用户列表和团体。我想我遇到了序列问题——在 wx 代码调用它们之前没有存储必要的变量，因为它们是同时启动的。也许为框架创建插入时间延迟等会有所帮助，但这感觉就像一个笨拙的解决方案，如果有解决方案的话。

另一种方法是将服务器引用直接传递给 wxPython 框架（和子面板/笔记本）。在这里我遇到了问题，因为回调需要一个不同的类，而 wx 需要同一个类中的信息......也许有一种方法可以强制它们进入同一个模型，但同样，感觉很笨拙（加上我还没有设法使它工作。

有解决这个问题的资源吗？标准方法？

如果这些可能说明我的方法存在问题......

这是我的服务器代码： http: //pastebin.com/84fmhsRV GUI 客户端代码： http: //pastebin.com/UimXe4RY

谢谢您的帮助。

我有一个动态组件模板，它将 XML 发布到代理数据库，然后使用组件表示工厂动态加载。

此 Xml 包含图像的 URL。我需要一个缩略图和一个完整的图像可用。我已经设法使用 Image Resizer TBB 来生成缩略图，但是，我希望这会添加可以引用的单独的包项目和二进制文件，但它似乎会覆盖完整大小的图像。

有没有一种方法可以在不编写自己的自定义 TBB 的情况下同时进入我的 Xml 和包？

在 Ubuntu 12.04 下启动 IBs TWS 时出错。我查看了标准输出，发现了以下日志消息。我检查了语言环境和 tz 设置，但无法解决。

我正在使用 ActiveMQ v5.6。它有一个消费者。它在大多数情况下都能正常工作。但有时，消息不会被发送，它们会堆积在队列中。但是，一旦我重新启动代理，它就会再次正常工作。我搜索以查看是否有其他人面临同样的问题，并发现了许多已报告该问题的网站。例如，

http://activemq.2283324.n4.nabble.com/Stuck-messages-Dispatch-issues-td2367852i20.html

但是所有这些帖子都可以追溯到 2008 年。这个问题已经解决了吗？还有其他人面临同样的问题吗？

假设我有以下 ActiveMQ 连接字符串：

故障转移:(tcp://broker1:61616,tcp://broker2:61616)?randomize=true

我正在从具有此配置的 Java 生产者向代理发送数千个请求。

有时我注意到所有消息最终只发送到一个代理，而另一个没有收到一条消息。

这是正常行为吗？

在 10 次测试中，我可能已经注意到这种行为几次。在其他时候，两个经纪人都收到了消息。

randomize=true 是如何工作的？

我在http://activemq.apache.org/failover-transport-reference.html上找到的唯一解释是：“使用随机算法从提供的列表中选择用于重新连接的 URI”

我正在用 C++ 构建一个客户端/服务器对，并且我已经使用它winsock进行通信。但是，我无法在 C++ 中找到任何库，通过它我可以实现一些东西，而不是直接从客户端向服务器发送请求，而是存储请求，然后与服务器通信。

是否有任何方法或库可以将请求发送到诸如经纪人之类的东西，反之亦然？将存储请求，然后将与服务器通信的东西。这些是我已经在使用的库：

我一直在为客户端代理服务器系统做这件事，但我并没有像以前那样使用winsock制作没有代理的客户端服务器。我也对这里的消息队列有一个想法：-http://msdn.microsoft.com/en-us/library/windows/desktop/ms707133(v=vs.85).aspx，例如：-

但是客户端代理服务器系统和妈妈中间件的任何头文件或引用。任何头文件都可以在 windows c++ 中执行。

我有一个激活 SP，它调用另一个 SP，它调用其他 SP 来插入和更新 TempDB 中存在的表。我已经使用具有 SA 权限的用户创建了队列，并且激活 SP 具有 SA 权限（尝试解决该问题）。

我继续收到此错误：对象“xxxxxxxx”、数据库“tempdb”、模式“dbo”的 SELECT 权限被拒绝。

我有能力在没有 Service Broker 的情况下执行该过程（直接调用 SPs Service Broker 正在调用）并且它工作正常。

有人有想法么？

谢谢

我的场景是使用批处理文件停止和启动消息流，其中我有 mqsi 命令。当我手动执行批处理文件时，我可以停止和启动流程。当我尝试使用在一个特定队列上启用的触发器执行批处理文件时，我收到以下错误，

C:\Program Files\IBM\MQSI\7.0\bin>mqsistopmsgflow DISSERTATION_MS -e WITH_WATCHDOG -m WITH_WATCHDOG.MainFlow_Webservice_With_WatchDog 线程“main”中的异常 java.lang.NoClassDefFoundError: com.ibm.broker.config.util.MessageFlowControl 原因： java.lang.ClassNotFoundException: com.ibm.broker.config.util.MessageFlowControl at java.net.URLClassLoader.findClass(URLClassLoader.java:434) 在 java.lang.ClassLoader.loadClass(ClassLoader.java:653) 在 sun。 misc.Launcher$AppClassLoader.loadClass(Launcher.java:358) 在 java.lang.ClassLoader.loadClass(ClassLoader.java:619)

找不到主类：com.ibm.broker.config.util.MessageFlowControl。程序将会退出。

我不确定，我在哪里做错了。请求您的帮助。谢谢。

问候， 吉文