1回答
我的要求是在处理流或发布队列中的任何内容之前，清除队列中的所有消息。我们正在使用rabbitMQ，并且由于某种原因，消息被塞进队列中，因此，当我们根据消息计算队列时，我们面临一些问题。因此，在下一次处理之前，我们必须清除队列。这里有多个队列，比如slave1、slave2、slave3，当api在process部分中被触发时，我们必须清除队列。
浏览 7提问于2022-03-02得票数 0
回答已采纳
当我部署我的应用程序时，mule不会在我的队列中创建一些消费者，但是如果我多次重新部署我的应用程序，它将完全创建所有的侦听器。下面是我代码的一部分：<amqp:connector name="amqpRabbitMQConnector" host="${rabbitmq.host}" username="${rabbitmq.username}" password=&
浏览 2提问于2016-01-10得票数 1
回答已采纳
1回答
是否有可靠的连接器可用于RabbitMQ到S3 (从RabbitMQ队列读取数据并发送到S3存储桶)？我发现很少有像和这样的
浏览 3提问于2019-01-24得票数 2
我尝试在Rabbitmq.But中运行队列，结果显示No connectors Found[]错误。如何解决这个问题？我使用composer require -yuldashev/laravel-queue-rabbitmq安装了驱动程序 我的.env文件中有这个 QUEUE_DRIVER=rabbitmqRABBITMQ_PORT=5672
<e
浏览 11提问于2019-02-06得票数 0
回答已采纳
我已经设置了一个连接器来从RabbitMQ队列中拉出并推送到Kafka主题中。连接器运行，队列清空。RabbitMQ消息的有效载荷都是JSON。我需要做些什么才能让JSON从Kafka中恢复过来？=500rabbitmq.network.recovery.interval.ms=10000
rabbitmq.topology.rec
浏览 22提问于2020-01-07得票数 0
回答已采纳
我的要求是在处理流或发布队列中的任何内容之前，清除队列中的所有消息(而不是删除队列，只清除队列中的消息)。我们正在使用rabbitMQ，并且由于某种原因，消息被塞进队列中，因此，当我们根据消息计算队列时，我们面临一些问题。因此，在下一次处理之前，我们必须清除队列。这里有多个队列，比如slave1、slave2、slave3，当api在process部分中被触发时，
浏览 21提问于2022-03-02得票数 0
我想让我的应用程序使用AMQ队列(RabbitMQ或ActiveMQ)与Apache Solr服务器交互。因此，我想问一下，是否有这样的实现，如果没有，我在哪里可以找到如何实现这样的连接器的信息。
浏览 0提问于2011-11-15得票数 1
回答已采纳
有没有任何方法来实现http连接器在Jasmin中发送消息(MT)？根据文档，jasmin只支持smpp连接器。我有4个短信提供商，我需要实现使用Jasmin。其中之一是使用SMPP协议，并且正在使用smpp连接器与jasmin一起工作。其他3有http协议(用params呼叫url发送SMS)。我想和jasmin一起使用http协议来使用它的路由和其他东西。
浏览 0提问于2018-08-06得票数 3
我使用kafka RMQ源连接器从RMQ队列获取数据。其中一个字段是base64encoded，它具有json结构。我正在使用提取转换来提取这个字段，但是我不确定如何解码这个字段，我试图编写自己的smt来解码这个字段，但是当我解码这个字段并试图将它放入记录的updatedvalue中时，我得到了错误的java.lang.ClassCastException非常感谢您的帮助。 下面是我的连接器配置。":"username",
浏览 26提问于2020-03-30得票数 0
回答已采纳
1回答
我使用以下配置为mule中的rabbitMQ创建了一个连接器，但问题是只创建了一个消费者，我想知道是否可以将mule配置为一次创建多个消费者。<amqp:connector name="amqpfiledetailConnector" username="${ra
浏览 2提问于2015-12-02得票数 0
我使用Spring cloud Spring服务连接器连接CloudFoundry上的Rabbitmq服务。因为当我们发送消息到队列时，我们需要使用publisherConfirm来检查ack。我不知道如何注入从cloud spring服务连接器获取的connectionFactory。
浏览 8提问于2017-11-29得票数 0
在我的MuleESB应用配置中，我有一个RabbitMQ队列，我希望使用多线程来使用消息，而顺序并不重要。" port="${rabbitmq_port}" fallbackAddresses="${rabbitmq_fallback_addresses}" virtualHost="${rabbitmq_virtual_hostConnector">
<reconnect-forever f
浏览 4提问于2018-11-02得票数 0
我想使用Mulesoft任意点演播室来收听rabbitMQ中的一些队列。但是，Anypoint的最新版本将不允许我从多个文档所建议的任意点Exchange安装AMQP连接器。首先，我找不到Anypoint的错误日志。但是工作目录中有一个隐藏的.log文件，但它也写着See the error log for details。是否有人对此有解决方案，或者知道任何点交换上的AMQP连接器有什么问题？
当我想安装另一个<e
浏览 3提问于2016-09-16得票数 0
2回答
我试着去理解，但是网上没有太多关于它的信息。
该产品的主要功能是什么?它与Apache Kafka或RabbitMQ有何不同？对我来说，它看起来就像其他许多队列服务器一样，带有一些预置的连接器，可以连接到第三方存储/队列。我想我可能真的漏掉了一点。也许它是基于云的基础设施的完美工具，或者提供与其他Netflix基础设施的无大脑集成，而其他人无法做到。有人能解释一下这项技术吗？
浏览 1提问于2015-01-14得票数 0
我的目标是在rabbitmq交换队列和kafka主题之间建立一个连接器。我从源代码https://github.com/apache/camel-kafka-connector下载并安装了连接器，为camel-rabbitmq-kafka-connector构建了它并解压缩了文件我还将plugin.path指向我在camel-rabbitmq-kafka-connector -Standalone.properties中解压缩ja
浏览 11提问于2020-09-25得票数 1
回答已采纳
我正在尝试做一个POC，我们需要连接RabbitMQ和Kafka。我的问题是，是否有可能将RabbitMQ和卡夫卡联系起来？提前感谢
浏览 0提问于2018-06-05得票数 2
在我的应用程序中，我们使用骆驼路径从RabbitMQ队列中读取消息。配置如下所示：
from("rabbitmq:myexchange?我能看到的是，所有的消息都被很快地消耗掉了，但是处理这些消息需要花费很多时间。需要处理许多小时，但这是否意味着50k消息存储在内存中？如果是这样的话，我想禁用此行为，因为我不想在进程停止时丢失消息.事实上，我们正在失去大部分的信息，即使当过程保持不动，这是更糟的。看起来连接器不是一次处理这么多消息的<
浏览 2提问于2019-10-17得票数 2
回答已采纳
我和我的团队正在构建一个度量环境，以便在业务逻辑的基础上处理每一个流程。我们用自定义代码包装了大部分代码，以便在RabbitMq中获得代码统计信息，然后将其发送到像ElasticSearch这样的数据收集器，以便根据这些指标制作一些有用的仪表板。我们想知道是否有任何连接器/独立软件可以发送Server 2016统计信息(查询统计数据、锁、等待命令、闩锁、ecc.)直接在RabbitMQ队列上。如有任何相关意见或建议，敬请见谅。提前谢谢。
浏览 1提问于2018-06-01得票数 0
回答已采纳
在索引到Elasticsearch之前，我试图解决数据去规范化的问题。现在，我的Postgres 11数据库配置了pgoutput插件，Debezium使用Postgresql将日志更改流到RabbitMq，然后通过对db进行反向查找并输入Elasticsearch来聚合日志更改尽管这很好，但是查找App来聚合数据是非常昂贵的，而且需要花费大量的执行时间(查询已经被改进了，但是它有大约10个联接，这使得它变得很马虎)。
我探索过的另一个选择是使用KStreams进行数据聚合。我在这里<e
浏览 9提问于2022-01-19得票数 0
回答已采纳
我很早就会询问关于客户端的通知。现在，我对服务器端的通知很感兴趣。特别是，我很感兴趣，事实上，通知通知所有服务器。或者还有其他方法来处理服务器集群？
马尔科
浏览 3提问于2015-10-06得票数 0
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
