broker

1热度

1回答

我正在使用UDP协议编写一个简单的客户端服务器NodeJS应用程序。这个应用程序的要点是它需要使用代理程序，在特定情况下，其功能是将发件人与接收程序链接起来。这些要求告诉我，发件人不需要知道收件人的IP地址和端口号 - 它只需要知道代理的相应IP和端口。之后，代理将根据服务器的IP和端口将客户的消息发送到服务器。为了澄清前款规定的，下面你会发现什么，我到目前为止已经做了说明（迷惑）： sende

0热度

1回答

使用qpid-proton向Azure服务总线发送持久消息 - url解析错误

我试图使用python-qpid-proton版本0.9.1将消息发送到Azure服务总线队列。示例/ examples/python/messenger/accept地址形式为amqps：//：@ /，并且我可以成功地将消息发送到Azure上的队列。问题在于我无法控制发生的事情，即我无法真正了解发送失败。最终我想坚持消息，以防万一互联网连接暂时关闭。示例代码示例/ python/db_sen

0热度

1回答

使用node.js创建应用程序时出错

我在美国South Bluemix地区。 BXNUI2032E: An error occurred when contacting Cloud Foundry to create a resource. Resource: service_bindings. Cloud Foundry message: "Service broker error: {"description"=>"Error

3热度

5回答

Java中是否有Kafka Monitoring API？

我正在尝试编写一个Java代码来获取消费者补偿，并为我们的kafka群集的滞后。是否有Java API来获取此信息？

1热度

2回答

如何停止接收LWT保留的消息？

为了测试，我创建了一个clean sessin = false和setWill(WILL_TOPIC, WILL_MSG.getBytes(), 1, true);的客户端，并运行该应用程序。后来，当我运行应用程序时，我设置了setWill(WILL_TOPIC, WILL_MSG.getBytes(), 1, false);，我收到了以前重新登录的LWT消息。如何停止接收它们？

1热度

1回答

WSO2 2.2.0中的消息重试和死信队列Message Broker

我们正在评估WSO2堆栈，特别是Message Broker v 2.2.0，并且无法使邮件重试限制工作。根据此文档页面，一旦客户端已经拒绝了一个消息10次，它将被从队列中移除并放置在死信队列中。 https://docs.wso2.com/display/MB220/Maximum+Delivery+Attempts 缺货排斥定义可以是： a）不发送在使用Session.CLIENT_ACKN

3热度

1回答

WebSphere Message Broker的 - 如何发送PCF消息

我们需要从MB流发出一些MQ命令。要走的路是发送PCF命令，但我不知道如何创建它。任何指针？塞巴斯蒂安。

0热度

1回答

关于MQTT PubAck与QoS等级一个

在this tutorial在message options 默认情况下，部分中，一个新的消息实例被设置为“至少一次”，服务质量的1质量（QoS），其指发送方将至少一次传递消息，如果没有它的确认，它会保持与重复标志设置发送它，直到确认轮番上涨，这是否意味着在setCallback listener-> onMessageArrived()我有要检查是否有消息到达，我必须再次用重复标志重新发送消息

-1热度

1回答

使用蚂蚁在栏上插入文件

我正在尝试制作一个ANT XML，用于构建，覆盖和部署一个栏文件。它工作正常，但我需要在META-INF文件夹（service.bar> service.appzip> META-INF）中插入一个文件，我真的不知道如何使用ANT来完成它。这是我的ANT XML： <project name="service" default="run"> <target name="run">

2热度

4回答

将activemq代理配置拆分为多个文件

我有一个activemq代理，我想将其配置拆分为多个文件。我想准备一个单独的配置文件，它会自动生成，并且只包含队列的定义。文件1：activemq.xml中 <beans ...> <broker ...> </broker> </beans> 文件2：queues.xml <beans ...> <broker ...> <destination