messagebroker

3热度

1回答

我遵循一个使用Spring Boot（1.4.X版）设置和运行嵌入式ActiveMQ的简单示例。这里是链接到例如https://spring.io/guides/gs/messaging-jms/ 我的类结构如下： @SpringBootApplication @EnableJms public class Application { @Autowired ConfigurableApp

1热度

1回答

Apache Kafka和Strom Clojure的实现

这是第一次实现流处理基础设施，我的毒性是storm 1.0.1, kafka 0.9.0和Clojure 1.5。现在我有一个使用邮件系统（RabbitMQ）的背景，我喜欢它有几个原因。易于安装和维护尼斯前端Web门户持久消息状态被保持在那里我可以开始一个消费者，它知道哪个消息没有被消耗掉。即“恰好一次” 然而它不能达到我想要的吞吐量。现在已经走过卡夫卡它很大程度上依赖于手动保持偏移（内

0热度

1回答

如何从Java返回MbElement []到ESQL？

我想将REFERENCE作为参数传递给Java方法并进行转换，然后我想以MbElement []的形式返回。直到现在我试了下面。我使用以下代码中ESQL CALL retrieveData(CAST(AGE AS INTEGER),OutputRoot.XMLNSC.employees) into RESULT; 调用Java方法如下： create function retrieveDa

0热度

1回答

在不等于服务器上的分布式计算

我有一组任务，每个任务都需要一定的条件才能满足。例如，任务需要100 Mb的RAM才能执行。另外我有多个服务器放置工作人员。每个工作人员都有一些配置来描述它拥有多少资源。例如，某些工作人员可以使用1 Gb的RAM来执行任务。是否有任何系统的工作人员之间的分配任务，使每个工人满足传递给它的任务的要求？或者，也许我可以以某种方式与消息代理（例如RabbitMQ）做到这一点？我知道写我自己的应用程序

0热度

2回答

在多个主题字符串上发布消息（IBM Integration Bus）

我有一个场景，我将使用MQ Input节点接收消息，并基于消息中存在的源系统的值，我需要形成主题字符串并发布信息。这是我的流程是如何的样子： MQInput - >计算 - >公布我用填充主题的价值： SET OutputRoot.Properties.Topic = 'TopicName /' || sourceName; 这适用于情况消息包含一个源系统。但是有可能消息包含多个源系统。是否可

0热度

1回答

如何访问来自JavaCompute节点的IIB消息的原始上下文

我试图在IIB 9流上实现JavaCompute节点，该节点将捕获输入JSON消息中的文本并通过网络将其发送到第三方目的地。看看消息对象结构，我可以看到一个包含json树的所有元素的树，但没有明显的方式将该树序列化为一个字符串。任何关于如何解决这个问题的指针将不胜感激。

1热度

1回答

为无根邮件创建队列

我有几个Java客户端将邮件发布为直接交换。我希望每个客户端都使用它们的ID作为路由键发布（或作为标题，我可以更改为标题交换）。如果有一个使用该生根密钥绑定的队列，它将发布给它，否则它将发布到全局队列。所以我的问题是，是否有可能有一个队列接收来自客户端的消息，这些客户端的生根键/头不能扎根到任何队列？看起来像一个默认队列的东西。谢谢。

0热度

2回答

创建Apache Apollo经纪人时出错

我下载并解压Apache Apollo经销人为described in their site。 ~/Developer/Web/MQTT/apache-apollo-1.7.1/bin/apollo create mybroker 我在终端下面输出了。 Creating apollo instance at: mybroker ERROR: mybroker/etc/log4j.propert

0热度

1回答

对Visual Studio 12没有DOTNET绑定支持2013

我一直在为Windows构建C++ Qpid消息传递代理，它使用boost库和CMake来完成实际构建。我运行命令cmake -G "Visual Studio 12 2013" C:\<home>\Downloads\qpid-cpp-0.34根据install instructions for windows，我得到了这个log output在结尾的消息：No DOTNET binding s

3热度

2回答

我是否需要像BizTalk那样的服务总线的消息代理？

我想将我的数据库连接到CRM，据我所知BizTalk是最好的选择。我知道BizTalk有它自己的消息系统，但考虑到我的数据的稳定性，这足够了吗？还是我应该在它们之间放置消息总线？