1回答
Kaazing主题订阅
、、、
在AMQP1.0和ActiveMQ中使用kaazing jms demo
https://demo.kaazing.com/demo/jms/javascript/jms-javascript.html注册/订阅新队列，并为应用服务器处理，并将消息发送回客户端从应用程序server.However看，订阅同一队列的客户端没有收到任何消息，原因是什么？
浏览 0提问于2014-07-22得票数 1
1回答
模拟消息进入异常队列的场景
、、、、
如何在oracle的队列/脱队列/浏览过程中模拟异常，从而使消息进入异常队列。我是新手，还没有通过订阅者和消费者。我所做的是.queue_table => 'demo_queue_table' queue_name => 'demo_queue('DEMO_QUEUE_E',enqueue
浏览 1提问于2015-08-05得票数 4
回答已采纳
1回答
未转发延迟消息。
、、
我将超时配置为使用RabbitMq中称为“RabbitMq”的外部管理器(必须手动创建)：以下是发送延迟消息的方式timeToScheduleInSeconds);
{ { Headers.Retu
浏览 2提问于2019-03-05得票数 2
回答已采纳
我有一个运行在服务器上的RabbitMQ消息代理，我正在尝试使用配置一个生产者和一个消费者。我的生产者每秒钟都在队列中创建消息，而我的使用者以相同的速度读取它们。但是，如果我停止了我的使用者，而生产者一直在推消息，当我再次重新启动我的使用者时，它将无法检索在它被关闭的那一段时间内创建的消息，只会收集从启动时产生的消息。当队列启动时，如何使我的使用者使用队列中的现有消息？这是我的消费者财产： stream:
浏览 0提问于2020-10-16得票数 0
回答已采纳
我可以用Java读写队列，可以用PHP读写消息，也可以用Java编写消息，也可以用PHP读取消息，但我不能用PHP编写消息，也不能用Java读取消息，这正是我真正想要做的。当我使用阿波罗的管理UI查看队列时，我可以看到我在我创建的测试队列中使用PHP/STOMP和使用Java/ActiveMQ发布的所有消息。下面是一个经过蒸馏的：
send.php写入测
浏览 3提问于2013-09-09得票数 4
我在Node.js中运行了一个STOMP客户端，它订阅了ActiveMQ中的一个队列。在使用cURL时，我可以使用以下命令将消息发送到队列(我在Node中运行的STOMP客户机立即使用这些消息)：
curl -d "body=message" http://sub.dummyhost.net:8161/demo/message/dispatch?它遵循了我们应该如何发送带有application/x表单-urlencoded数
浏览 3提问于2015-12-01得票数 0
回答已采纳
路由密钥是否仅用于将特定交换的消息路由到特定队列？当我们提到以下命令时，aRe在那里创建了一些对象：
channel.ExchangeDeclare(exchange:"demo_exchange"，类型：“->”；-> channel.BasicPublish(交换："demo_exchange"，routingKey："hello"，basicProperties: null，body: body)；
浏览 4提问于2016-09-01得票数 1
回答已采纳
2回答
我的Azure功能如下- public static void Run([ServiceBusTrigger("%Demo-Queue%",jObject.ToString()); }
但是信息在死信队列中消息格式也是correct.Any线索吗？
浏览 1提问于2018-07-25得票数 1
回答已采纳
当我向队列中添加某些内容时，messageText将被编码，如何将其删除，使其成为明文？在这里看到队列中的消息文本var queueClient = new QueueClient(ConnectionString, "paymentfiles2");我在Azure.Storage.Queues标准2.0项目中使用.NET，Version=12.4.2.0
浏览 3提问于2020-09-18得票数 0
回答已采纳
我想使用一个非常简单的spring启动应用程序向rabbitmq队列demo-queue发送消息： package com.example.demo;
import java.time.LocalDateTime因此启动供应商并向其查询新消息。但是，我没有看到rabbitmq中的队列被创建并填充了生成的消息。 pom.xml为： <?xml version="1.0" encoding="UTF-8"?</
浏览 32提问于2020-11-24得票数 1
回答已采纳
基本上，一切都很好，我设法：
更新在“执行级别”，根本不要使用侦听器，只需循环dequeue函数即可:它等待第一条/下一条消息
CREATE O
浏览 3提问于2018-07-24得票数 1
回答已采纳
卡夫卡中的demo.incoming话题堆积如山。kafka-run-class.sh kafka.tools.GetOffsetShell \
--
浏览 1提问于2019-07-07得票数 1
2回答
下面是我接收到的.Net核心和rabbitMQ的例外情况: AMQP操作被中断:由Peer、code=405发起的AMQP关闭原因，text='RESOURCE_LOCKED无法获得对vhost '/‘中锁定的队列’演示-队列‘的独占访问。= Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(message));
channel.BasicPublish("", "demo-queueGetString(bod
浏览 4提问于2022-11-29得票数 0
回答已采纳
2回答
我需要一个示例，说明如何在C或C++中使用cURL (或其他一些东西，此时我对任何内容都开放)通过HTTP对cURL队列进行读/写。我在C#中有工作代码，但没有帮助。任何帮助都是非常感谢的，谢谢。
浏览 8提问于2010-10-06得票数 4
应用程序侦听队列A，如果有来自队列A消息，则执行一些处理，然后将另一条消息发送到队列B。DistributorControlAddress="" DistributorDataAddress=""> <add Messages="Demo.Messages在"DemoQueueB“中总是有一条消息
<?xm
浏览 6提问于2011-08-08得票数 4
回答已采纳
我正在尝试实现一种策略，当activemq队列中的消息到期时，它们将转到另一个死信队列，而不是移动到默认的死信队列ActiveMQ.DLQ。我的问题是如何为单个队列配置/指定死信队列。我已经将我的应用程序配置为生成队列，如下所示 <from uri="direct:insertToQueue" />&quo
浏览 2提问于2018-07-12得票数 1
1回答
我有以下版本的芹菜和狂犬病-
狂犬病3.1.1
//client.phpcelery = Celery('tasks', broker='amqp://guest:guest@localhost:5672//')Task tasks.add[ph
浏览 4提问于2013-12-18得票数 13
回答已采纳
我尝试使用RabbitTemplate (使用Spring Boot)在队列上发布消息，并收到此消息。我已经试着寻找解决方案了。SimpleMessageConverter only supports String, byte[] and Serializable payloads, received: com.example.demo.SimpleMessage
浏览 75提问于2019-03-16得票数 5
回答已采纳
我在Oracle AQ的异常队列中有很多消息(500 K)(我不知道过期的消息被移动到另一个队列中，所以我没有为这些消息创建使用者)。我现在需要的是能够快速删除这些消息。我已经读过，通过delete清除队列表不是个好主意，因为它可能导致不一致的状态。所以我把下面的过程组合在一起，但是它只清除了50条消息/秒
EXECUTE dbms_aqadm.start_queue(queue_name => 'AQ$_MESSAGES_E
浏览 3提问于2013-04-16得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
云直播
实时音视频活动推荐
腾讯云开发者
