messagebroker

0热度

1回答

我工作在我的第一个IOT POC上，设备通常会每小时/天产生一次传感器数据。我打算有架构这样的： - 1传感器数据输入（设备到后端方向）共享主题 - 每个设备将首先订阅其自己的特定主题又名/设备/ {ID} /通知现在，在传感器数据提交给共享主题后，我打算让设备进入深度睡眠状态（设备只能通过wifi数据包或定时器唤醒），在此状态下，与代理的TCP连接丢失。问题：设备重新启动并重新建立到MQT

1热度

1回答

MessageQueue的契约：MessageQueues情况下的样本提供程序测试

我已经通过参考pact repo中给出的示例示例编写了MessageProvider的样本Pact测试。以下是正在生成用于提供者期望的消息的PACT json文件的消费者测试。在API的情况下，为了验证PACT，我可以使用“pact-jvm-provider-maven”插件来完成此操作。在这种情况下，PACT将根据提供商的实际托管API服务进行验证。我的问题是，如何在MessageQueue

0热度

1回答

订阅一群使用RabbitMQ的消费者？

我不能完全肯定这是提出正确的地方，但我对的RabbitMQ的运作问题，实现发布/订阅消息系统。我调查的RabbitMQ，看它是否适合我工作的公司的需要，我找不到任何回答这些问题无论是在官方文档或在互联网上：是否有可能为一消费者订阅一组发布者？我想这是可能的，如果我们想要订阅的所有发布者都将他们的消息发送给交换机，然后将它们转发给订阅者。执行此操作最适合的呼气类型是什么？是否可以订阅一组主题？例

0热度

2回答

IBM Integration Bus和xsd：anyType

我正在使用IIB v9 mxsd消息定义。我想将其中一个XML元素定义为xsd：anyType类型。然而，在我可以选择的类型列表中，只有anySimpleType和anyUri是可能的（除了字符串，整数等所有其他类型）。我该如何解决这个限制？

0热度

1回答

ActiveMQ将现有的队列转换为CompositeQueue

我会尽我所能解释这一点。正如我存储我的数据，我从我的ActiveMQ的队列接收在若干不同的位置，我已决定建立一个复合队列，所以我可以分别处理每个位置的数据。我遇到的问题是，我目前拥有的队列在生产环境中。看起来，将名为A的队列更改为也称为A的组合队列A具有名为B和C的虚拟目标，这会导致我失去现有队列中的所有数据。它不会启动前面的消息。目前，我正在创建一个名称不同的新CompositeQueue，

0热度

1回答

MQTT，是否有可能为本地主机以外的所有人阻止出版物，并将订阅向所有人开放？

我想要做的只是从本地主机发布数据。但我需要允许Web上的任何用户订阅该主题，是否可以使用MQTT？怎么样？如果不是，我是否有其他的选择来满足这些细节。其他信息：使用MQTT协议张贴。使用Websockets进行订阅。使用Mosquitto作为经纪人。

0热度

1回答

ng-repeat有问题

我正在使用角度1.0.5的Rails 3.2.11应用程序。目前，用户将从下拉列表中选择一个Cycle，然后使用ng-resource从我的控制器返回一堆JSON。这里是方法 $scope.update = function(cycleId) { Cycle.get({action: cycleId}, function(resource) { $scope.select

1热度

1回答

如何在Masstransit/RabbitMQ中组织队列？

我想知道消费消息的最佳实践。我已经阅读了MassTransit文档，并且正在寻找这方面的内容，但是我没有得出任何结论。我有一个api（托管公交车实例），正在发布消息。这些消息是多种多样的，因为这个API不是微服务（购买，销售等的消息）。如何组织我的消费者/队列？一个队列类型的过程？例如，一个用于购买，另一个用于销售，这个解决方案可能涉及许多流程，我不确定它是否是一个好的解决方案。如果我想购买

0热度

1回答

嵌入式中间件ActiveMQ的配置

这是我的配置，用于将消息发送给嵌入式中间件。另外，第一个bean方法用于创建和启动代理。它不返回任何实例。此代码是否启动代理？我已经使用JMS模板的发送方法将消息发送到下面提到的主题。我已经为经纪人创建和运行写了createbrokerervice。 @Configuration @EnableJms public class JMSConfig { public static

0热度

1回答

什么是消息代理重试intval和如何配置

我已经使用WSO2 Message Broker MB300服务器来通信每个微服务。这是使用主题连接。在仪表板“耐用主题订阅”部分和“消息传递挂起数量”列消息中显示为挂起。这个数字正在增加。消息传递延迟或重试间隔的任何配置？