- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
几天前我问了同样的问题:Unable to "Peek" messages from an Azure Service Bus Queue using AMQP and Node 。我再次问同样的问题,但有一些差异(因此,请不要将此问题标记为与其他问题重复):
nodeamqp10
库,但是根据该库的 Github 页面上的一些评论,我最终使用了 rhea
而不是 nodeamqp10
库。这是我正在使用的新代码:
var client = require('rhea');
const keyName = 'MyCustomPolicy';
const sasKey = 'SAS Key'
const serviceBusHost = 'account.servicebus.windows.net';
const queueName = '003';
client.on('connection_open', (context) => {
context.connection.open_sender({
target: { address: `${queueName}/$management` }
});
});
client.once('sendable', (context) => {
console.log('messages can be sent now....');
var receiver = context.connection.open_receiver({
source: { address: `${queueName}/$management` },
autoaccept: false,
target: { address: 'receiver-link' }
});
receiver.once('receiver_open', (context) => {
console.log('receiver is now open....');
});
receiver.once('message', (context) => {
console.log('message received by receiver....');
console.log(context.message);
});
var messageBody = {
'from-sequence-number': 1,
'message-count': 5
};
const msg = {
application_properties: {
operation: 'com.microsoft:peek-message'
},
body: client.types.wrap_map(messageBody),
reply_to: 'receiver-link'
};
context.sender.send(msg);
console.log('message sent....');
});
client.connect({
transport: 'tls',
host: serviceBusHost,
hostname: serviceBusHost,
username: keyName,
password: sasKey,
port: 5671,
reconnect_limit: 10
});
现在,当我运行此代码时,我从 Azure 服务总线返回 500
错误:
{
"application_properties":
{
"statusCode":500,
"errorCondition":"amqp:internal-error",
"statusDescription":"The service was unable to process the request; please retry the operation. For more information on exception types and proper exception handling, please refer to http://go.microsoft.com/fwlink/?LinkId=761101 Reference:ab667ed6-1565-4728-97b7-6ae4a33468b9, TrackingId:538f93a1-2c07-4bc0-bf41-dc00d7ae963c_B13, SystemTracker:account-name:Queue:003, Timestamp:8/2/2018 7:43:52 AM",
"com.microsoft:tracking-id":"538f93a1-2c07-4bc0-bf41-dc00d7ae963c_B13"
}
}
我什至检查了错误消息中包含的链接 ( http://go.microsoft.com/fwlink/?LinkId=761101 ),但该链接上没有提及 amqp 相关错误。
与上一个问题一样,如果我使用地址作为队列名称而不是queue-name/$management
,我能够获取消息,但消息被锁定并且传递计数因为消息正在增加。此外,它返回队列中的所有消息,而不是我请求的 5 条消息。
我不确定我做错了什么。有人可以帮忙吗?
最佳答案
在Azure服务总线团队的帮助下,我找到了这个问题的解决方案(事实上,他们给了我这个解决方案)。本质上 messageBody
的元素应该使用 AMQP 类型正确编码。
以下代码有效:
var messageBody = {
'from-sequence-number': client.types.wrap_long(1),
'message-count': client.types.wrap_int(5)
};
const msg = {
application_properties: {
operation: 'com.microsoft:peek-message'
},
body: messageBody,
reply_to: 'receiver-link'
};
关于node.js - 使用 AMQP、rhea 和 Node 从 Azure 服务总线队列查看消息时获取 "amqp:internal-error",我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/51831383/
在 Spring AMQP 项目中, 如果 messageProperties 没有 messageId,它们总是创建 messageId。 像这样.. if (this.createMessageI
我不确定我对 errorHandler 和 returnExceptions 的理解是否正确。 但这是我的目标:我从 App_A 发送了一条消息,使用 @RabbitListener 在 App_B
就目前而言,这个问题不适合我们的问答形式。我们希望答案得到事实、引用资料或专业知识的支持,但这个问题可能会引发辩论、争论、投票或扩展讨论。如果您觉得这个问题可以改进并可能重新打开,visit the
我们希望将大型机放在总线上。我相信是AS400。为此,我想让 CICS 大型机向代理发送 AMQP 消息。有几十个AMQP客户端,包括JMS客户端。我对大型机上可能发生的事情了解不够,无法判断是否可以
我们希望将大型机放在公共(public)汽车上。我相信它是AS400。为此,我想让 CICS 大型机向代理发送 AMQP 消息。有几十个 AMQP 客户端,包括 JMS 客户端。我不太了解大型机上的可
我即将实现一个基于 PHP 的系统,该系统使用 RabbitMQ。我可以看出那里有 2 个成熟的库:PECL AMQP和 php-amqp . 我将同时为客户端和工作人员使用 PHP。 有人对这两个库
我正在使用 RabbitMQ 和 ruby-amqp与 Rails。当 Controller 收到消息时,我执行以下操作: def create AMQP.start("amqp://localh
我有两个困惑。 1.如果消息监听器抛出RuntimeException,SimpleMessageListenrContainer会停止吗?2.如果SimpleMessageListenerConta
我们在绑定(bind)到 Rabbit MQ 实例的 Java 应用程序的日志中遇到以下异常。 这是必须要注意的事情,表示Spring AMQP的实现中存在问题,还是可以忽略的事情?在后一种情况下,此
场景:微服务从 RabbitMQ 队列中获取消息,将其转换为对象,然后微服务对外部服务进行 REST 调用。 它将处理成千上万条这样的消息,如果我们知道外部 Rest 服务已关闭,有没有办法告诉我的消
我有一个使用带有 webflux 的 Boot 2.0 的应用程序,并且有一个端点返回 ServerSentEvent 的 Flux。这些事件是通过利用 spring-amqp 从 RabbitMQ
我正在尝试使用 streadway/amqp 连接到 RabbitMQ 总线Go 的驱动程序。我正在处理重新连接例程,为此,我有一个 rabbitMQConsume 函数调用 rabbitMQConn
我正在尝试通过 SSL 连接到 RabbitMQ。我遵循了此处链接的 RabbitMQ SSL 文档 https://www.rabbitmq.com/ssl.html根据 RabbitMQ SSL
这些 amqp 客户端库之间有什么区别?哪一个是最推荐的?主要区别是什么? 最佳答案 我会推荐 amqp.node和 bramqp通过 node-amqp。 node-amqp 有很多错误并且维护不善
我得到的错误: 2019-12-09 06:39:33.189 ERROR 107132 --- [http-nio-8082-exec-5] o.a.c.c.C.[.[.[/].[dispatche
所以我已经让 MQTT -> MQTT 和 AMQP -> AMQP 工作;不过,MQTT -> AMQP 的翻译似乎在某处不起作用。这是我的测试,如果我的“监听器”也在使用 paho 的 MQTT
我得到的错误: 2019-12-09 06:39:33.189 ERROR 107132 --- [http-nio-8082-exec-5] o.a.c.c.C.[.[.[/].[dispatche
几天前我问了同样的问题:Unable to "Peek" messages from an Azure Service Bus Queue using AMQP and Node 。我再次问同样的问题
我有一个当前与 RabbitMQ 集成的组件。我想将 RabbitMQ 替换为 Azure Event Hub,因为我们现在位于云中。 AMQP 0.9.1 与 AMQP 1.0 兼容吗?交换会无缝进
我有一个当前与 RabbitMQ 集成的组件。我想将 RabbitMQ 替换为 Azure Event Hub,因为我们现在位于云中。 AMQP 0.9.1 与 AMQP 1.0 兼容吗?交换会无缝进
我是一名优秀的程序员,十分优秀!