rabbitmq

-1热度

1回答

这次可以在RabbitMQ中为呼叫处理程序存储时间吗？ RabbitMQ是否支持这个？

0热度

1回答

我试图测试Kubernetes上的气流。调度程序，工作者，队列和Web服务器都在不同的部署上，我使用Celery Executor来运行我的任务。除了调度程序无法排队工作以外，一切正常。当我从Web UI或CLI手动执行它时，Airflow能够正常运行我的任务，但我试图测试调度程序以使其工作。我的配置几乎一样，因为它是在单个服务器上： sql_alchemy_conn = postgresql

-1热度

3回答

ASP.NET表单开发建议

我一直负责更新整个站点的联系和反馈表单。不太确定有多少表格，但至少有20种表格在不断增加。我知道，一旦这个到位，它会在那里一段时间。另外，负责添加新表单的人员没有太多的代码体验，因此我试图尽可能方便地创建新表单。我的目标是创建一个基类，允许人呼叫的通用形式添加变量，将增加任何预设场以定制表单添加一些简单的值，作为谁应该通过电子邮件发送，以及用于营销目的的表单名称是什么。数据库表已经创建，

0热度

1回答

为什么我们应该在接收者中声明队列的名字？

我正在学习RabbitMQ。我不明白为什么在receive_logs.pyexample我们设定的交换类型： channel.exchange_declare(exchange='logs', exchange_type='fanout') 以及与此交流结合队列的名称： channel.queue_bind(exchange='logs', queue=q

0热度

1回答

如何删除rabbitmq中的消息（pika）

如何删除发布和接收的消息，在rabbitmq 我正在用python测试rabitmq，同样的消息还在继续发布和接收，如何避免这种情况。我怎样才能删除公布并收到

0热度

1回答

如何对RabbitMQ Cluster进行性能测试以做进一步的微调？

我已经创建了一个RabbitMQ群集，它正在对由应用程序生成的消息进行排队。我需要对集群进行性能测试，以便找出集群的整体效率，并做出决定进行进一步的微调以提高性能。我们用PerfTest java工具尝试过。但实现不了多少。

0热度

1回答

如何注册一个队列，并且它是RabbitMQ和Spring的独占使用者/侦听器？

我有以下问题需要解决：我想实现一个简单的使用RabbitMQ消息传递的延迟重试机制。我有一个基础设施，可以让我延迟传递信息。我可以有任何想要在运行时利用这种延迟重试机制的感兴趣的参与者。参与者只想给我提供2个细节和消息： 1.队列名称，他们希望在延迟T秒后传递消息。 2.队列的消费者（比如消息的消费者。）我试图做到以下几点： private void startSeparateListene

0热度

3回答

RabbitMQ连接错误“没有指定的端点可达”

我在服务器和我的系统上安装了rabbitmq服务。我想使用RPC模式： var factory = new ConnectionFactory() { HostName = "158.2.14.42", Port = Protocols.DefaultProtocol.DefaultPort, UserName = "Administrator", Pas

0热度

1回答

Apache进程不会在与RabbitMQ断开连接后死亡

我试图在我的项目中使用Server Side Events机制。（这类似于类固醇上的长轮询）来自“Sending events from the server”字幕的例子效果非常好。几秒钟后，断开连接，apache进程终止。此方法工作正常。但是！如果我尝试使用RabbitMQ，则在浏览器从服务器断开连接后，Apache不会导致进程中断（es.close()）。并且进程保持原样并在docker

2热度

1回答

Android - 将GLSurfaceView.Renderer置于睡眠状态（如Thread.sleep（20））OnDrawFrame方法之外

我想控制GLSurfaceView.Renderer的渲染速率。我在扩展GLSurfaceView的类中实现了一个线程，并将它定期放在一个while（true）循环中休眠，这样做并没有减慢渲染器的速度。有一个很好的回答here，建议通过使用Renderer.onDrawFrame（）方法中的Thread.sleep来使GL线程进入睡眠状态。我想从Renderer类外部处理它。当一个明确的调用需要传