consumer 相关问题

消费者服务中的异常管理(微服务架构)

我们有一个由三个表组成的微服务,它的数据由事件填充,这些表相互关联,出于任何原因我们收到一条消息,该消息具有外键 ano...

回答 0 投票 0

在 SQS 上接收消息时 i/o 超时问题和内存泄漏 https 使用

AWS SDK 版本:v1.38.19 版本:go1.15.7 高山 3.7 我正在使用标准队列 我像这样在我的应用程序中立即初始化 SQS 连接; // 连接到 SQS...

回答 1 投票 0

当我尝试使用 BiCionsumer 从我的列表中删除一个值时,它不起作用

我有以下问题: 目标:从列表中删除“危险”== true 的动物; 约束:必须使用其中一个功能接口(消费者、谓词、函数或供应商)...

回答 2 投票 0

Java 中 Map 和 Consumer 的多态性使用

我有这样的课 公共课 Foo { private final Map> context = new LinkedHashMap<>(); public void save(消费者&...

回答 1 投票 0

为什么我的 Flutter 表单无法保存它们的值?

我正在使用以下代码创建一个简单的多步骤问答表单,但表单似乎无法保存它们的值,当我转到第二个表单并返回时,textFormField val...

回答 0 投票 0

为什么在 Flutter 中使用 provider 创建的多步骤表单中表单不保存它们的值?

我正在使用以下代码创建一个简单的多步骤问答表单,但表单似乎无法保存它们的值,当我转到第二个表单并返回时,textFormField val...

回答 2 投票 0

如何在 java 8 中将地图转换为地图的消费者?

我有一个将 (Consumer>) 作为方法参数的方法 A。 public void myMethodA(Consumer>> someMap) { 然而,我遇到...

回答 1 投票 0

Flutter:如何防止在提供者更改时重建整个列表

我有一个 ListView.builder,它使用一个简单提供者的消费者。 每个项目都需要异步加载一些东西,所以我使用的是 FutureBuilder。 当我将一个项目添加到列表中时,整个列表...

回答 1 投票 0

itemCount

itemCount 似乎没有被消费者更新。这会导致 GridView 滚动不起作用。 返回消费者( 建设者:(上下文,collectionData,孩子)=> GridView.bui ...

回答 1 投票 0

RocketMQ消费者等待结果回调。

我使用RocketMQ,想在每次新请求时从队列中获取消息 @Service public class GetMessageFromQueue extends BaseObject { @Resource private RocketMQTemplate rocketMQTemplate; @Value("${...")。

回答 1 投票 0

Kafka消费者没有收到消息

我在visual sdudio上使用C#。我创建了两个项目,一个是生产者的,另一个是消费者的。我想在WinForm上同时发送和接收消息。一开始,我成功地运行了生产者......。

回答 1 投票 0

MassTransit消费者从未收到信息

我正在按照在ASP.NET Core应用程序中使用RabbitMQ和Autofac的MassTransit的文档构建一个演示应用程序。我的程序代码: namespace MessageDemo { public ...

回答 1 投票 0

RabbitMQ消费者:已关闭异常。

我有一个简单的RabbitMQ发布者和消费者代码,如下所示。首先,我在My_Tasks队列中创建了10条不同数量的消息。当我试图获取这些消息时,一个接一个,并使用autoAck标志......。

回答 1 投票 0

| Celery

In production server, I am getting the following error in celery console which never happened before. I found the same issue in other posts, they are saying give valid url but the url i have given in ...

回答 1 投票 0

问题:通过契约进行的消费者驱动的合同测试

我正在为大学项目编写一个小型程序。我想用契约框架来测试它。不幸的是,尽管没有错误,但没有为我创建Pact.json文件。我的消费者是...

回答 1 投票 0

带有.NET的RabbitMQ-EventingBasicConsumer VS DefaultBasicConsumer

每次使用以下示例发布消息时,我都能收到消息:var Consumer = new EventingBasicConsumer(channel);消费者。收到+ =(ch,ea)=> {...

回答 1 投票 0

DropdownButtonFormField无法重建

我正在尝试以编程方式更新所选值。我使用了各种方法,包括Consumer等,并确保在值...

回答 1 投票 1

Spring Cloud Stream Kotlin消费者问题

我正在尝试使用Kotlin的Spring Cloud Stream。我写了一个简单的使用者,如下所示:@Bean fun log():Consumer {return Consumer {person:Person-> println(“ ...

回答 2 投票 1

从Kafka消费数据

[我正在通过为以下三个属性指定类来使用来自Kafka Topic的消息:--property key.deserializer = org.apache.kakfa.common.serialization.StringDesrializer --...

回答 1 投票 1

消费者无法在60000毫秒内启动;任务执行器是否有足够的线程来支持容器并发?

记录器错误:使用者无法在60000毫秒内启动;任务执行器是否有足够的线程来支持容器并发?我该如何解决?非常感谢。我试图...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.