问题标签 [messagebroker]

我需要在几个（3 个和更多）应用程序之间发送（同步）数据。Message Broker 必须解决几个问题：

1. 向未知数量的接收者广播一条消息。
2. 控制成功红色。应用程序只能成功/读取消息一次或仅在分配给此应用程序（连接）的一段时间后。或者以某种方式在客户端解决它，而不会对服务器/MB造成高负载
3. 在所有接收者成功读取消息后删除消息。它可以在中央应用程序的客户端解决，但本机可能性将很有用。

只有一个应用程序必须知道整个系统中存在多少应用程序，否则它可以转移到 Message Broker 的职责。

我已经尝试过：Amazone SQS - 它是纯队列，没有任何高级工具。RabbitMQ - 不可能在不删除消息的情况下读取消息。（可能以其他方式存在）

如果我创建一个环境变量，它将存在于执行组内的所有流中吗？我需要一个必须在同一执行组中的两个流之间共享的值。

我正在尝试添加一个简单的sleep函数来扩展基本 ESQL API。

Java实现：

ESQL 参考：

这是错误跟踪：

所以我正在从流的请求注释中读取一个 XML 文件。并且需要将 XML 数据转换为 blob。

场景是：

在 linux 上运行的 IBM WMB V8 在 MQ 消息中提供了一个用户 ID 列表。对于每个用户 ID，我需要连接到 Windows 框（可能是 samba 共享），然后将此用户 ID 传递给 Windows 可执行文件，即

C:\temp\command.exe 1234 C:\temp\command.exe 5678

此命令的输出会将这个用户的图像从数据库输出返回到目录。

WMB 然后去检索这个图像并以某种方式映射（用户 ID => 图像）并在某处更新数据库。

在不涉及 Windows 机器上的其他处理器的情况下，这种情况在 WMB 中是否可行？

我看不到任何可以帮助解决此问题的节点，我希望我必须将用户 ID 列表转储到一个文件中并使用 perl 或类似方法来处理命令和图像捕获并将这些作为消息或其他内容返回给 WMB .

问候，

萨帕托斯

http://markallanson.net/wordpress/index.php/category/rsmb/

我试图按照上面的链接将 mqtt 设置为 Windows 服务以在后台静默运行。但是，无法按照作者在步骤一和二中所说的话。也没有任何评论/问题的空间。

我想这样做，这样我就不需要每次启动远程机器时都输入用户名和密码。

如果您知道如何设置。在 Windows 中不插入密码的任何替代选项。或任何建议请分享。谢谢

在 WebSphere message Broker 8 中，新的 .NET 计算节点非常棒，可以连接基于 Windows 的服务并处理 Windows 事务。但是，调试代码并非易事。我希望你们中的任何人对此有一些线索：

简短信息：

WMB 中的消息流是在基于 Eclipse 的 IDE 中开发的，并且有一个调试器来逐步执行逻辑。它与执行 Java 逻辑的 Java 计算节点无缝集成。

.NET 计算节点逻辑实际上是 Visual C# 中 .DLL 项目的类中的一个方法（理论上可以是任何 Visual XX 风格）。似乎 Visual Studio 能够启动外部程序来调试 DLL 项目。但是，在这种情况下，很难将 WebSphere Message Broker 作为外部应用程序启动。有没有办法将调试附加到仅由此特定 WMB 消息流使用的特定 DLL？

要求：我希望消息在队列中持续存在直到onMessage()成功执行。如果在执行期间发生任何异常onMessage()并且如果它未被处理，则应将消息重新传递给侦听器。

我将 Glassfish v2 作为应用程序服务器。我正在使用 OpenMQConnectionFactory 和 JmsTemplate 在队列上发送消息。 请注意，我没有使用 MDB。

我尝试将 AUTO_ACKNOWLEDGE 作为确认模式，但在未重新传递异常引发的消息时在侦听器中。

消息生产者.java

公共无效发送消息（最终字符串响应流）{

SampleJMSConsumer.java

然后我尝试this.jmsTemplate.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE);在我调用的侦听器中使用并在我调用 message.acknowledge();的catch块中调用session.recover()仍然消息未重新传递。

SampleJMSConsumer.java

}

当我在调试模式下运行程序并在代理管理控制台中的队列上发送消息时，我能够看到消息的数量，但只要调用 onMessage() 的消息数量减少一。这意味着消息被消费并从队列中删除。该消息是否被视为“已送达”？请帮助我理解为什么发生异常时消息没有重新传递？

提前致谢。

消息代理中 biphttplisetner 的作用是什么？它只是用于 HTTP 节点吗？（HTTPInput、HTTPReply 等）还是消息代理的某些其他功能需要它。

如果 tnsnames.ora 中指定的数据库连接 url 不正确，我看到 biphttplistener 不会出现。这个httplistener和数据库有什么联系？

谢谢

我正在继承现有的以 ESQL 为中心（计算节点）的 WMB 流，该流通过 ODBC DSN 访问其数据库。我更喜欢使用可配置的服务来代替 ODBC DSN 来访问数据库，这是我在以 Java 为中心的流（JavaCompute 节点）中使用的。

是否可以配置 Compute 节点通过可配置服务与 db 通信？